Я не могу запустить flink (1.0.3) процесс в цеппине. Он находится на рассмотрении, и web ui не записывает процесс: как в кластере, так и в локальном режиме. Флинк отлично работает в командной строке и intellij. Я построил zeppelin как mvn clean package
. У кого-нибудь была подобная проблема? Мне нужно изменить zeppelin-env.sh, чтобы исправить filk? Я не могу убить процесс в ZEPPELIN веб-интерфейс должен был использовать ./bin/zeppelin-daemon.sh restart
flink - zeppelin - не отвечает
1
A
ответ
0
Я использую Flink 1.2, но у меня была та же проблема.
Я сделал две вещи, и это сработало для меня.
Прежде всего, обновите свою версию. После этого в интерпретаторе я изменил значение хост = локально на ваш IP-адрес локального хоста.
Во-вторых, убейте все профайлы Flink в терминале, просто используйте web ui Zeppelin.
Вы можете проверить все, что происходит штраф Writting:
%flink
senv
res0: org.apache.flink.streaming.api.scala.StreamExecutionEnvironment = [email protected]48388d9f
Позвольте мне знать, как это происходит. С уважением! :)
Смежные вопросы
- 1. Как написать содержимое Flink var на экран в Zeppelin?
- 2. Почему сервер zeppelin на искровом кластере не отвечает?
- 3. Apache - Zeppelin build не удалось на Ubuntu
- 4. Ошибка сборки Zeppelin
- 5. Zeppelin: Как перезапустить sparkContext в zeppelin
- 6. Zeppelin: как скачать или сохранить ноутбук Zeppelin?
- 7. Flink: Использование памяти
- 8. Apache Zeppelin не загружается libmesos.so
- 9. flink-streaming-java недоступен в Apache Flink
- 10. Ошибки возникают при сборке Zeppelin
- 11. Flink: Выполнение файла Jar в кластере Flink
- 12. flink - кластер, не использующий кластер
- 13. Flink СЕР не является детерминированным
- 14. org.apache.flink.api.java.io.jdbc.JDBCInputFormat НЕ ВНУТРИ FLiNK JARS
- 15. Не удается установить приложение flink
- 16. Flink Queryable состояние не работает
- 17. Flink RMQSource
- 18. Отладка Zeppelin Dependency Management
- 19. Apache zeppelin process умер
- 20. Datastax Spark Zeppelin Authentication
- 21. Установите zeppelin на окна
- 22. Spark, ADAM и Zeppelin
- 23. Zeppelin and BigQuery
- 24. Zeppelin соединение отказано
- 25. Apache Zeppelin - Highcharts
- 26. Фильтр Zeppelin по запросам
- 27. Что такое apache zeppelin?
- 28. Проверка подлинности LDAP Zeppelin
- 29. Zeppelin и SqlContext
- 30. Автоматические записные книжки zeppelin
Что сказали ваши журналы Zeppelin-Flink? 'zeppelin_dir/logs/* flink * log' Эй, я проделал некоторую работу с Flink + Zeppelin. Когда такое происходит, наиболее вероятной причиной в моем опыте является Zeppelin работает фон, который оставил осиротевшей версии Flink. Тем более, что Flink-Zeppelin даже не работает в локальном режиме. Заставляет меня думать, что он не может привязываться к этому порту. Если вы используете Zeppelin в поле * nix, попробуйте что-то вроде 'ps aux | grep zeppelin' – rawkintrevo