0
Kann Flink mehrere Aufträge an Stream lokale Umgebung mit Web Ui per Java-Code anhängen?Kann Flink mehrere Jobs an Stream lokale Umgebung mit Web Ui per Java-Code anhängen?
mein Code wie diese
env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(config);
env.addSource(...);
env.addSink(...);
env.execute("stream job1");
Was ich möchte, ist eine Schleife durch, dies zu tun und job2 job3 auf der gleichen Umgebung mit Web-UI-Managment befestigen. Wie kann dies in Java-Code getan werden?
Ich habe versucht, env2 = StreamExecutionEnvironment.getExecutionEnvironment(), zu verwenden, aber es scheint, als ob der neue Job2 nicht Attatch zu Env ich zuvor erstellt wurde.
mir bitte helfen Vielen Dank im Voraus
ja, ich habe versucht, es wiederherzustellen, aber ich bekomme Fehler, sagen, dass die Adresse Bindung bereits verwendet wird, denke ich env versuchen, die gleichen Jobmanager-Adresse aus irgendeinem Grund zu verwenden. Ich werde meine Anfrage bald mit dem Code und der Fehlermeldung aktualisieren. Danke für die Hilfe. – zt1983811
Sie haben Recht. Das Problem ist, dass die zugrunde liegende 'LocalStreamEnvironment' für jeden 'execute' Aufruf einen neuen' LocalFlinkMiniCluster' erstellt, der dieselben Ports verwendet. Dies könnte die Probleme verursachen. Versuchen Sie, Flink-Jobs gleichzeitig auf demselben lokalen Cluster auszuführen? –
Ja Ich versuche mehrere Jobs in einem lokalen lokalen Cluster auszuführen. – zt1983811