You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/12/12 02:15:15 UTC
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #1347
See <https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/1347/display/redirect?page=changes>
Changes:
[thw] [BEAM-5058] remove unused envdir parameter
------------------------------------------
[...truncated 411.96 KB...]
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- Query12/Query12.Debug/ParMultiDo(Monitor)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- Query12/Query12.Debug
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- Query12/Query12.Stamp
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- Query12/Query12.Stamp/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- Query12/Query12.Stamp
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- Query12.Format
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- Query12.Format/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12.Format
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- Query12.DevNull
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- Query12.DevNull/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12.DevNull
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: leaveCompositeTransform-
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Starting execution of Flink program.
Dec 12, 2018 2:15:13 AM org.apache.flink.api.java.ExecutionEnvironment createProgramPlan
INFO: The job has 0 registered types and 0 default Kryo serializers
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkRunner run
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)
at org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:184)
at org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:157)
2018-12-12T02:15:13.452Z Running query:BOUNDED_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true; streamTimeout:60
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:1173)
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)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkRunner fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files from the classpath: will stage 171 files. Enable logging at DEBUG level to see which files will be staged.
2018-12-12T02:15:13.455Z Generating 100000 events in batch mode
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Executing pipeline using FlinkRunner.
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Translating pipeline to Flink program.
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkExecutionEnvironments createBatchExecutionEnvironment
INFO: Creating a Batch Execution Environment.
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkExecutionEnvironments createBatchExecutionEnvironment
INFO: Using Flink Master URL local:8081.
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkExecutionEnvironments determineParallelism
WARNING: No default parallelism could be found. Defaulting to parallelism 1. Please set an explicit parallelism with --parallelism
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: enterCompositeTransform-
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | visitPrimitiveTransform- BoundedSideInputJoin.ReadBounded
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- NexmarkUtils.GenerateSideInputData
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor/ParMultiDo(Monitor)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.CreatePCollectionView
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug/ParMultiDo(Monitor)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin.Format
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- BoundedSideInputJoin.Format/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin.Format
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin.DevNull
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- BoundedSideInputJoin.DevNull/ParMultiDo(Anonymous)
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin.DevNull
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: leaveCompositeTransform-
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Starting execution of Flink program.
Dec 12, 2018 2:15:13 AM org.apache.flink.api.java.ExecutionEnvironment createProgramPlan
INFO: The job has 0 registered types and 0 default Kryo serializers
Dec 12, 2018 2:15:13 AM org.apache.beam.runners.flink.FlinkRunner run
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)
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:1173)
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)
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Daemon worker,5,main]) completed. Took 5.373 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-nexmark:run'.
> Process 'command '/usr/local/asfpackages/java/jdk1.8.0_191/bin/java'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2m 59s
67 actionable tasks: 63 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/pjswks6jcn56e
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal :
beam_PostCommit_Java_Nexmark_Flink #1351
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/1351/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #1350
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/1350/display/redirect?page=changes>
Changes:
[robertwb] Use environment to control worker startup in FnApiRunner.
[robertwb] [BEAM-6094] Implement external environment for Portable Beam.
------------------------------------------
[...truncated 413.40 KB...]
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- Query12/Query12.Debug/ParMultiDo(Monitor)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- Query12/Query12.Debug
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- Query12/Query12.Stamp
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- Query12/Query12.Stamp/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- Query12/Query12.Stamp
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- Query12.Format
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- Query12.Format/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12.Format
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- Query12.DevNull
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- Query12.DevNull/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12.DevNull
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: leaveCompositeTransform-
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Starting execution of Flink program.
Dec 12, 2018 12:19:22 PM org.apache.flink.api.java.ExecutionEnvironment createProgramPlan
INFO: The job has 0 registered types and 0 default Kryo serializers
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkRunner run
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)
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)
2018-12-12T12:19:22.228Z Running query:BOUNDED_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true; streamTimeout:60
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:1173)
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)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkRunner fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files from the classpath: will stage 171 files. Enable logging at DEBUG level to see which files will be staged.
2018-12-12T12:19:22.230Z Generating 100000 events in batch mode
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Executing pipeline using FlinkRunner.
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Translating pipeline to Flink program.
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkExecutionEnvironments createBatchExecutionEnvironment
INFO: Creating a Batch Execution Environment.
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkExecutionEnvironments createBatchExecutionEnvironment
INFO: Using Flink Master URL local:8081.
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkExecutionEnvironments determineParallelism
WARNING: No default parallelism could be found. Defaulting to parallelism 1. Please set an explicit parallelism with --parallelism
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: enterCompositeTransform-
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | visitPrimitiveTransform- BoundedSideInputJoin.ReadBounded
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- NexmarkUtils.GenerateSideInputData
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor/ParMultiDo(Monitor)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.CreatePCollectionView
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug/ParMultiDo(Monitor)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin.Format
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- BoundedSideInputJoin.Format/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin.Format
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin.DevNull
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- BoundedSideInputJoin.DevNull/ParMultiDo(Anonymous)
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin.DevNull
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: leaveCompositeTransform-
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Starting execution of Flink program.
Dec 12, 2018 12:19:22 PM org.apache.flink.api.java.ExecutionEnvironment createProgramPlan
INFO: The job has 0 registered types and 0 default Kryo serializers
Dec 12, 2018 12:19:22 PM org.apache.beam.runners.flink.FlinkRunner run
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)
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:1173)
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)
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 8,5,main]) completed. Took 5.004 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-nexmark:run'.
> Process 'command '/usr/local/asfpackages/java/jdk1.8.0_191/bin/java'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 3m 21s
67 actionable tasks: 67 executed
Publishing build scan...
https://gradle.com/s/f6vlhpdakqfnc
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #1349
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/1349/display/redirect>
------------------------------------------
[...truncated 411.65 KB...]
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- Query12/Query12.Debug/ParMultiDo(Monitor)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- Query12/Query12.Debug
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- Query12/Query12.Stamp
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- Query12/Query12.Stamp/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- Query12/Query12.Stamp
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- Query12.Format
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- Query12.Format/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12.Format
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- Query12.DevNull
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- Query12.DevNull/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12.DevNull
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: leaveCompositeTransform-
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Starting execution of Flink program.
Dec 12, 2018 6:18:52 AM org.apache.flink.api.java.ExecutionEnvironment createProgramPlan
INFO: The job has 0 registered types and 0 default Kryo serializers
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkRunner run
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)
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)
2018-12-12T06:18:52.537Z Running query:BOUNDED_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true; streamTimeout:60
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:1173)
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)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkRunner fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files from the classpath: will stage 171 files. Enable logging at DEBUG level to see which files will be staged.
2018-12-12T06:18:52.539Z Generating 100000 events in batch mode
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Executing pipeline using FlinkRunner.
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Translating pipeline to Flink program.
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkExecutionEnvironments createBatchExecutionEnvironment
INFO: Creating a Batch Execution Environment.
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkExecutionEnvironments createBatchExecutionEnvironment
INFO: Using Flink Master URL local:8081.
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkExecutionEnvironments determineParallelism
WARNING: No default parallelism could be found. Defaulting to parallelism 1. Please set an explicit parallelism with --parallelism
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: enterCompositeTransform-
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | visitPrimitiveTransform- BoundedSideInputJoin.ReadBounded
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- NexmarkUtils.GenerateSideInputData
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor/ParMultiDo(Monitor)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.CreatePCollectionView
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug/ParMultiDo(Monitor)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin.Format
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- BoundedSideInputJoin.Format/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin.Format
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin.DevNull
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- BoundedSideInputJoin.DevNull/ParMultiDo(Anonymous)
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin.DevNull
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: leaveCompositeTransform-
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Starting execution of Flink program.
Dec 12, 2018 6:18:52 AM org.apache.flink.api.java.ExecutionEnvironment createProgramPlan
INFO: The job has 0 registered types and 0 default Kryo serializers
Dec 12, 2018 6:18:52 AM org.apache.beam.runners.flink.FlinkRunner run
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)
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:1173)
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)
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 4.91 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-nexmark:run'.
> Process 'command '/usr/local/asfpackages/java/jdk1.8.0_191/bin/java'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2m 52s
67 actionable tasks: 63 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/n4aj7vqy5xpro
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Java_Nexmark_Flink #1348
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/1348/display/redirect?page=changes>
Changes:
[github] [BEAM-2943] Fix typo in filename on FlinkRunner page
------------------------------------------
[...truncated 411.86 KB...]
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- Query12/Query12.Debug/ParMultiDo(Monitor)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- Query12/Query12.Debug
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- Query12/Query12.Stamp
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- Query12/Query12.Stamp/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- Query12/Query12.Stamp
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- Query12.Format
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- Query12.Format/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12.Format
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- Query12.DevNull
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- Query12.DevNull/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- Query12.DevNull
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: leaveCompositeTransform-
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Starting execution of Flink program.
Dec 12, 2018 5:02:08 AM org.apache.flink.api.java.ExecutionEnvironment createProgramPlan
INFO: The job has 0 registered types and 0 default Kryo serializers
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkRunner run
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)
at org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:184)
2018-12-12T05:02:08.191Z Running query:BOUNDED_SIDE_INPUT_JOIN; exportSummaryToBigQuery:true; streamTimeout:60
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:1173)
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)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkRunner fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files from the classpath: will stage 171 files. Enable logging at DEBUG level to see which files will be staged.
2018-12-12T05:02:08.194Z Generating 100000 events in batch mode
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Executing pipeline using FlinkRunner.
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Translating pipeline to Flink program.
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkExecutionEnvironments createBatchExecutionEnvironment
INFO: Creating a Batch Execution Environment.
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkExecutionEnvironments createBatchExecutionEnvironment
INFO: Using Flink Master URL local:8081.
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkExecutionEnvironments determineParallelism
WARNING: No default parallelism could be found. Defaulting to parallelism 1. Please set an explicit parallelism with --parallelism
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: enterCompositeTransform-
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | visitPrimitiveTransform- BoundedSideInputJoin.ReadBounded
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- NexmarkUtils.GenerateSideInputData
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/GenerateSequence
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements/Map
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData/MapElements
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- NexmarkUtils.GenerateSideInputData
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor/ParMultiDo(Monitor)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Monitor
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Snoop
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.VoidKeyToMultimapMaterialization
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap/View.CreatePCollectionView
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/View.AsMap
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid/ParDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/IsBid
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids/AsBid
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/justBids
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin/BoundedSideInputJoin.JoinToFiles
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug/ParMultiDo(Monitor)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Debug
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | | enterCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | | visitPrimitiveTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | | leaveCompositeTransform- BoundedSideInputJoin/BoundedSideInputJoin.Stamp
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin.Format
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- BoundedSideInputJoin.Format/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin.Format
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator enterCompositeTransform
INFO: | enterCompositeTransform- BoundedSideInputJoin.DevNull
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator visitPrimitiveTransform
INFO: | | visitPrimitiveTransform- BoundedSideInputJoin.DevNull/ParMultiDo(Anonymous)
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: | leaveCompositeTransform- BoundedSideInputJoin.DevNull
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkBatchPipelineTranslator leaveCompositeTransform
INFO: leaveCompositeTransform-
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkRunner run
INFO: Starting execution of Flink program.
Dec 12, 2018 5:02:08 AM org.apache.flink.api.java.ExecutionEnvironment createProgramPlan
INFO: The job has 0 registered types and 0 default Kryo serializers
Dec 12, 2018 5:02:08 AM org.apache.beam.runners.flink.FlinkRunner run
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)
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:1173)
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)
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 4.937 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-nexmark:run'.
> Process 'command '/usr/local/asfpackages/java/jdk1.8.0_191/bin/java'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2m 53s
67 actionable tasks: 63 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/tixs2233s5wpq
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org