Flink with Python (Jython), как мне импортировать другие фреймворки? - PullRequest
0 голосов
/ 07 марта 2019

Я сейчас пишу программу "Flink" на Python. Для этой программы мне нужны некоторые библиотеки, например "redis" или "netaddr".

import redis

Нормальный импорт не выполняется. Как я могу импортировать их правильно?

Запуск выполнения программы. Не удалось запустить план: нулевая трассировка (большинство последний вызов последним): Файл "", строка 1, в файле "/Tmp/flink_streaming_plan_5d3febe9-4056-4f69-b4e7-7fbfbb2d4d3b/json_parser_flink.py", строка 11 в ImportError: нет модуля с именем redis

Программа не содержала задание Flink. Возможно, вы забыли позвонить execute () в среде выполнения.

...