2017-10-11 250 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知识产权不公开。