2017-10-11 142 views
1

Apache Flink提供REST API以提交其作業。我試圖從本地機器調用該REST API,但獲得java.net.UnknownHostException。到目前爲止,我成功通過SSH運行我的作業,但需要通過REST API運行作業,以便我可以直接從我的應用程序/代碼運行作業。通過Flink REST API在AWS EMR上運行Flink作業

+0

你可以跟我們分享堆棧跟蹤嗎? –

+0

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

+0

請訪問http ://docs.aws .amazon.com/emr/latest/ManagementGuide/emr-connect-master-node.html –

回答

0

它可以通過Flink REST API。我的問題是我的EMR知識產權不公開。