You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Etienne Chauchot (JIRA)" <ji...@apache.org> on 2018/12/12 13:41:00 UTC
[jira] [Commented] (BEAM-6216) Flink post commits are failing
[ https://issues.apache.org/jira/browse/BEAM-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16718982#comment-16718982 ]
Etienne Chauchot commented on BEAM-6216:
----------------------------------------
Can it be due to flink version upgrade ?
> Flink post commits are failing
> ------------------------------
>
> Key: BEAM-6216
> URL: https://issues.apache.org/jira/browse/BEAM-6216
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Reporter: Etienne Chauchot
> Priority: Major
>
> Various post commit jenkins script are failing with
> {code:java}
> java.net.UnknownHostException: local{code}
> stacktrace:
> {code:java}
> SEVERE: Pipeline execution failed
> java.net.UnknownHostException: local
> at java.net.InetAddress.getAllByName0(InetAddress.java:1281)
> at java.net.InetAddress.getAllByName(InetAddress.java:1193)
> at java.net.InetAddress.getAllByName(InetAddress.java:1127)
> at java.net.InetAddress.getByName(InetAddress.java:1077)
> at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils.getRpcUrl(AkkaRpcServiceUtils.java:170)
> at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils.getRpcUrl(AkkaRpcServiceUtils.java:135)
> at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:83)
> at org.apache.flink.client.program.ClusterClient.<init>(ClusterClient.java:158)
> 2018-12-04T19:09:01.639Z Running query:BOUNDED_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true; streamTimeout:60
> at org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:184)
> at org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:157)
> at org.apache.flink.client.RemoteExecutor.start(RemoteExecutor.java:157)
> at org.apache.flink.client.RemoteExecutor.executePlanWithJars(RemoteExecutor.java:208)
> at org.apache.flink.client.RemoteExecutor.executePlan(RemoteExecutor.java:193)
> at org.apache.flink.api.java.RemoteEnvironment.execute(RemoteEnvironment.java:173)
> at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.executePipeline(FlinkPipelineExecutionEnvironment.java:122)
> at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:110)
> at org.apache.beam.sdk.Pipeline.run(Pipeline.java:313)
> at org.apache.beam.sdk.Pipeline.run(Pipeline.java:299)
> at org.apache.beam.sdk.nexmark.NexmarkLauncher.run(NexmarkLauncher.java:1172)
> at org.apache.beam.sdk.nexmark.Main$Run.call(Main.java:89)
> at org.apache.beam.sdk.nexmark.Main$Run.call(Main.java:78)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)