flink - zeppelin - не отвечает - Отличная библиотека

Я не могу запустить flink (1.0.3) процесс в цеппине. Он находится на рассмотрении, и web ui не записывает процесс: как в кластере, так и в локальном режиме. Флинк отлично работает в командной строке и intellij. Я построил zeppelin как mvn clean package. У кого-нибудь была подобная проблема? Мне нужно изменить zeppelin-env.sh, чтобы исправить filk? Я не могу убить процесс в ZEPPELIN веб-интерфейс должен был использовать ./bin/zeppelin-daemon.sh restart flink - zeppelin - не отвечает

источник

2016-07-31 Karol Sudol

Что сказали ваши журналы Zeppelin-Flink? 'zeppelin_dir/logs/* flink * log' Эй, я проделал некоторую работу с Flink + Zeppelin. Когда такое происходит, наиболее вероятной причиной в моем опыте является Zeppelin работает фон, который оставил осиротевшей версии Flink. Тем более, что Flink-Zeppelin даже не работает в локальном режиме. Заставляет меня думать, что он не может привязываться к этому порту. Если вы используете Zeppelin в поле * nix, попробуйте что-то вроде 'ps aux | grep zeppelin' – rawkintrevo

Я использую Flink 1.2, но у меня была та же проблема.

Я сделал две вещи, и это сработало для меня.

Прежде всего, обновите свою версию. После этого в интерпретаторе я изменил значение хост = локально на ваш IP-адрес локального хоста.

Во-вторых, убейте все профайлы Flink в терминале, просто используйте web ui Zeppelin.

Вы можете проверить все, что происходит штраф Writting:

%flink 
senv 
res0: org.apache.flink.streaming.api.scala.StreamExecutionEnvironment = [email protected]48388d9f

Позвольте мне знать, как это происходит. С уважением! :)

источник

2017-05-26 09:35:51 Borja

flink - zeppelin - не отвечает

ответ

Смежные вопросы