Я хочу запустить dask.dataframe с помощью jython - PullRequest
0 голосов
/ 06 декабря 2018

Я хочу запустить dask в java-процессе с помощью jython.

Я установил dask [complete] с помощью команды pip.

, но процесс java вызывает ImportError: dask

так как я могу исправить эту ошибку?

package test;
import org.python.core.*;
import org.python.util.*;
public class TestJython {
private static PythonInterpreter pi;

public static void main(String[] args) throws PyException {
    pi = new PythonInterpreter();
    PySystemState sys = pi.getSystemState();
    sys.path.append(new PyString("/usr/local/lib/python2.7/dist-packages"));
    pi.exec("import dask.dataframe as dd");
    }
}

журнал ошибок:

Exception in thread "MainThread" Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "/usr/local/lib/python2.7/dist-packages/dask/dataframe/__init__.py", line 31, in <module>
    raise ImportError(str(e) + '\n\n' + msg)
ImportError: Missing required dependencies ['numpy']

1 Ответ

0 голосов
/ 10 декабря 2018

Похоже, PythonInterpreter не инициализирован с правильной настройкой PYTHONPATH.Это не проблема с Dask, а с тем, как вы инициализируете PythonInterpreter.Похоже, вам может потребоваться установить системное свойство python.path или использовать переменную среды JYTHONPATH: https://www.stefaanlippens.net/jython_and_pythonpath/.

Обратите внимание, что команда dask не имеет опыта работы с dask в Jython и не может гарантировать, чтобудет работать или быть исполнителем.

...