Ich weiß Jobs können von flink oder flink.bat an JobManager gesendet werden. Ich möchte wissen, ob Flink Java API zur Verfügung stellt, um Jobs an JobManager zu senden?Bietet Flink Java-API, um Jobs an JobManager zu senden?
Ja. Abhängig vom Typ des Clusters, den Sie verbinden möchten, gibt es mehrere Implementierungen des ClusterClients (https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/client/program/ClusterClient.html).
Es kann Aufträge entweder blockierend (synchron) oder losgelöst (asynchron) ausführen. Eine Möglichkeit zur Bereitstellung eines Jobs besteht darin, ein PackagedProgram bereitzustellen, das aus einer JAR-Datei mit einer Hauptklasse und mehreren unterstützenden JAR-Dateien besteht (zusätzliche Bibliotheken, die speziell für den Job benötigt werden).
Sie können diese Testklasse betrachten ClientTest.java, kann Ihnen helfen, mehr Konfigurationsparameter siehe configuration.
Vielen Dank. – Hao
Aber ich sehe keine Methode in ClusterClient, um die JobManager-Adresse anzugeben. Können Sie mir sagen, wie ich die Adresse angeben soll? – Hao