flink - Zeppelin - antwortet nicht - Hervorragende Bibliothek

Ich kann flink (1.0.3) Prozess in Zepplin nicht ausführen. Es steht aus und WebUi zeichnet den Prozess nicht auf: sowohl im Cluster- als auch im lokalen Modus. Flink selbst funktioniert gut in der Befehlszeile und intellij. Ich baute Zeppelin als mvn clean package. Hat jemand ein ähnliches Problem? Muss ich Zeppelin-env.sh ändern, um Filk zu korrigieren? Ich bin nicht in der Lage Prozess in zeppelin Web-UI zu töten hatte ./bin/zeppelin-daemon.sh restart flink - Zeppelin - antwortet nicht

Quelle

2016-07-31 Karol Sudol

Was sagten Ihre Zeppelin-Flink Protokolle? 'zeppelin_dir/logs/* flink * log' Hey, ich habe mit Flink + Zeppelin gearbeitet. Wenn so etwas passiert, ist die wahrscheinlichste Ursache meiner Erfahrung, dass Zeppelin den Hintergrund ausführt, der eine verwaiste Version von Flink laufen ließ. Zumal Flink-Zeppelin nicht einmal im Localmode arbeitet. Lässt mich denken, dass es nicht an diesen Port binden kann. Wenn Sie Zeppelin auf einer * nix-Box ausführen, versuchen Sie etwas wie 'ps aux | Grep Zeppelin' – rawkintrevo

ich verwenden bin mit Flink 1.2, aber ich hatte das gleiche Problem.

Ich tat zwei Sache und es hat für mich funktioniert.

Zunächst, aktualisieren Sie Ihre Version. Danach änderte ich im Interpreter den Wert host = local auf die IP-Adresse Ihres lokalen Hosts.

Zweitens, töten Sie alle Prozesse von Flink im Terminal, verwenden Sie einfach Web-Ui von Zeppelin.

Sie alles überprüfen können feinen Schriftfelter wird:

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

Lassen Sie uns wissen, wie es geht. Grüße! :)

Quelle

2017-05-26 09:35:51 Borja

flink - Zeppelin - antwortet nicht

Antwort

Verwandte Themen