You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Kenneth Knowles (Jira)" <ji...@apache.org> on 2020/08/22 15:13:00 UTC
[jira] [Updated] (BEAM-8004) Flink Load tests are flaky
[ https://issues.apache.org/jira/browse/BEAM-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kenneth Knowles updated BEAM-8004:
----------------------------------
Labels: flake (was: )
> Flink Load tests are flaky
> --------------------------
>
> Key: BEAM-8004
> URL: https://issues.apache.org/jira/browse/BEAM-8004
> Project: Beam
> Issue Type: Bug
> Components: testing
> Reporter: Lukasz Gajowy
> Assignee: Kamil Wasilewski
> Priority: P1
> Labels: flake
> Fix For: 2.16.0
>
> Time Spent: 1h 50m
> Remaining Estimate: 0h
>
> https://builds.apache.org/view/A-D/view/Beam/view/All/job/beam_LoadTests_Python_Combine_Flink_Batch/
> https://builds.apache.org/view/A-D/view/Beam/view/All/job/beam_LoadTests_Python_GBK_Flink_Batch/
> The tests are mostly failing (they sometimes succeed) due to issues with Dataproc cluster. The error:
> {code:java}
> root: DEBUG: java.net.UnknownHostException: beam-loadtests-python-gbk-flink-batch-68-w-10.c.apache-beam-testing.internal
> 13:35:25 at java.net.InetAddress.getAllByName0(InetAddress.java:1281)
> 13:35:25 at java.net.InetAddress.getAllByName(InetAddress.java:1193)
> 13:35:25 at java.net.InetAddress.getAllByName(InetAddress.java:1127)
> 13:35:25 at java.net.InetAddress.getByName(InetAddress.java:1077)
> 13:35:25 at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils.getRpcUrl(AkkaRpcServiceUtils.java:167)
> 13:35:25 at org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils.getRpcUrl(AkkaRpcServiceUtils.java:133)
> 13:35:25 at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:89)
> 13:35:25 at org.apache.flink.client.program.ClusterClient.<init>(ClusterClient.java:159)
> 13:35:25 at org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:185)
> 13:35:25 at org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:158)
> 13:35:25 at org.apache.flink.client.RemoteExecutor.start(RemoteExecutor.java:152)
> 13:35:25 at org.apache.flink.client.RemoteExecutor.executePlanWithJars(RemoteExecutor.java:202)
> 13:35:25 at org.apache.flink.client.RemoteExecutor.executePlan(RemoteExecutor.java:187)
> 13:35:25 at org.apache.flink.api.java.RemoteEnvironment.execute(RemoteEnvironment.java:173)
> 13:35:25 at org.apache.beam.runners.flink.FlinkBatchPortablePipelineTranslator$BatchTranslationContext.execute(FlinkBatchPortablePipelineTranslator.java:200)
> 13:35:25 at org.apache.beam.runners.flink.FlinkPipelineRunner.runPipelineWithTranslator(FlinkPipelineRunner.java:92)
> 13:35:25 at org.apache.beam.runners.flink.FlinkPipelineRunner.run(FlinkPipelineRunner.java:68)
> 13:35:25 at org.apache.beam.runners.fnexecution.jobsubmission.JobInvocation.runPipeline(JobInvocation.java:78)
> 13:35:25 at {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)