2017-10-11 3 views
1

Apache Flink stellt REST API bereit, um seine Jobs zu senden. Ich versuche, diese REST-API von meinem lokalen Rechner aus aufzurufen, bekomme aber java.net.UnknownHostException. Bisher habe ich meinen Job erfolgreich über SSH ausgeführt, muss aber einen Job über die REST API ausführen, damit ich Jobs direkt aus meiner Anwendung/meinem Code ausführen kann.Flink-Job auf AWS EMR über Flink-REST-API ausführen

+0

Können Sie die Stack-Trace mit uns teilen? –

+0

java.net.UnknownHostException: http: //ip-333-33-33-33.ec2.internal \t bei java.net.InetAddress.getAllByName0 (InetAddress.java:1280) \t bei java.net.InetAddress. getAllByName (InetAddress.java:1192) \t bei java.net.InetAddress.getAllByName (InetAddress.java:1126) \t bei java.net.InetAddress.getByName (InetAddress.java:1076) \t bei org.apache.flink .runtime.rpc.akka.AkkaRpcServiceUtils.getRpcUrl (AkkaRpcServiceUtils.java:173) \t bei org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils.getRpcUrl (AkkaRpcServiceUtils.java:138) \t ... –

+0

Siehe http : //docs.aws .amazon.com/emr/neuste/ManagementGuide/emr-connect-master-node.html –

Antwort

0

Dies ist über Flink REST API möglich. Das Problem in meinem Fall war, dass mein EMR IP nicht öffentlich war.