See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/188/display/redirect?page=changes>
Changes:
[yifanzou] [BEAM-4963] update org.apache.httpcomponents
[yifanzou] [BEAM-4906] upgrade org.apache.derby
[apilloud] [BEAM-4761] Run Nexmark in thread pool
[aaltay] Automate "Run validation tests" step (#6081)
------------------------------------------
[...truncated 6.60 MB...]
INFO: Creating FileSystem stream leak safety net for task CHAIN MapPartition
(MapPartition at SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap
(FlatMap at SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output) (1/1)
(ad04af95910bd35b3a5568c198226ab4) [DEPLOYING]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output) (1/1)
(ad04af95910bd35b3a5568c198226ab4) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output) (1/1)
(ad04af95910bd35b3a5568c198226ab4) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output) (1/1)
(ad04af95910bd35b3a5568c198226ab4) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output) (1/1)
(ad04af95910bd35b3a5568c198226ab4) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output) (1/1)
(ad04af95910bd35b3a5568c198226ab4) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output) (1/1)
(ad04af95910bd35b3a5568c198226ab4).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) switched from CREATED to SCHEDULED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap
(FlatMap at SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output) (1/1)
(ad04af95910bd35b3a5568c198226ab4) [FINISHED]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output)
ad04af95910bd35b3a5568c198226ab4.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) switched from SCHEDULED to DEPLOYING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1) (attempt #0) to
localhost
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Debug/ParMultiDo(Monitor).output) (1/1)
(ad04af95910bd35b3a5568c198226ab4) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) switched from CREATED to DEPLOYING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task CHAIN MapPartition
(MapPartition at SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap
(FlatMap at SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) [DEPLOYING]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) switched from CREATED to SCHEDULED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap
(FlatMap at SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) [FINISHED]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output)
6f22982de8a6ddaa44f0155e5fafc355.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) switched from SCHEDULED to DEPLOYING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1) (attempt #0) to localhost
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7/SqlQuery7.Stamp/ParMultiDo(Anonymous).output) (1/1)
(6f22982de8a6ddaa44f0155e5fafc355) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) switched from CREATED to DEPLOYING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task CHAIN MapPartition
(MapPartition at SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) [DEPLOYING]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) switched from CREATED to SCHEDULED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) [FINISHED]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) f46c6b0f1b4c7459c4c8922b28c2d688.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) switched from SCHEDULED to DEPLOYING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1) (attempt #0) to localhost
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.Format/ParMultiDo(Anonymous).output) (1/1)
(f46c6b0f1b4c7459c4c8922b28c2d688) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) switched from CREATED to DEPLOYING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task CHAIN MapPartition
(MapPartition at SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap
at SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) [DEPLOYING]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap
at SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) [FINISHED]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea)
(1/1) (0eb9ce94a4697413a5bf765ec5e854ce) switched from CREATED to SCHEDULED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output)
e9b4769e3766c66eadccff183f2b20a9.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea)
(1/1) (0eb9ce94a4697413a5bf765ec5e854ce) switched from SCHEDULED to DEPLOYING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea) (1/1) (attempt
#0) to localhost
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
SqlQuery7.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
SqlQuery7.DevNull/ParMultiDo(Anonymous).output) (1/1)
(e9b4769e3766c66eadccff183f2b20a9) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea) (1/1).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea)
(1/1) (0eb9ce94a4697413a5bf765ec5e854ce) switched from CREATED to DEPLOYING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea) (1/1)
(0eb9ce94a4697413a5bf765ec5e854ce) [DEPLOYING]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea) (1/1)
(0eb9ce94a4697413a5bf765ec5e854ce) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea) (1/1)
(0eb9ce94a4697413a5bf765ec5e854ce) [DEPLOYING].
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea)
(1/1) (0eb9ce94a4697413a5bf765ec5e854ce) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea)
(1/1) (0eb9ce94a4697413a5bf765ec5e854ce) switched from DEPLOYING to RUNNING.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea)
(1/1) (0eb9ce94a4697413a5bf765ec5e854ce) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea) (1/1)
(0eb9ce94a4697413a5bf765ec5e854ce).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea) (1/1)
(0eb9ce94a4697413a5bf765ec5e854ce) [FINISHED]
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea)
0eb9ce94a4697413a5bf765ec5e854ce.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3eda5cea)
(1/1) (0eb9ce94a4697413a5bf765ec5e854ce) switched from RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-0803231743-9bbde9e9 (ea3233c1848ca90e8da8a88a93219f93)
switched from state RUNNING to FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job ea3233c1848ca90e8da8a88a93219f93 reached globally terminal state
FINISHED.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-0803231743-9bbde9e9(ea3233c1848ca90e8da8a88a93219f93).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job ea3233c1848ca90e8da8a88a93219f93.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection f8bde1d72b16ae406b7e7716fd8ed46b:
JobManager is shutting down..
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.rpc.akka.AkkaRpcActor
onReceive
INFO: The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has
not been started yet. Discarding message
org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is
started.
Aug 03, 2018 11:17:58 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
aee9465c7f40498d5023b77ade5c42d1@akka://flink/user/jobmanager_11 for job
ea3233c1848ca90e8da8a88a93219f93 from the resource manager.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Aug 03, 2018 11:17:58 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{93190e7e27343ea676466ee9a45b3ccd}, jobId:
ea3233c1848ca90e8da8a88a93219f93).
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job ea3233c1848ca90e8da8a88a93219f93 from job leader monitoring.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job ea3233c1848ca90e8da8a88a93219f93.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_10.
Aug 03, 2018 11:17:58 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Aug 03, 2018 11:17:58 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcherdb5a3465-7e3b-4f18-9552-912ff0cf4f49.
Aug 03, 2018 11:17:58 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcherdb5a3465-7e3b-4f18-9552-912ff0cf4f49.
Aug 03, 2018 11:17:58 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 9d60565eea3858f5e8cc4767c8fa0b53 from the
SlotManager.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-6e015c2b-0eba-4568-967d-7df25023a8f8
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_10.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Aug 03, 2018 11:17:58 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcherdb5a3465-7e3b-4f18-9552-912ff0cf4f49.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:37549
Aug 03, 2018 11:17:58 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Aug 03, 2018 11:17:58 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 14528 msecs
Aug 03, 2018 11:17:58 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Aug 03, 2018 11:17:58 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@af99a2c0
2018-08-03T23:17:58.517Z Waiting for main pipeline to 'finish'
2018-08-03T23:17:58.520Z DONE SqlQuery7
2018-08-03T23:17:58.521Z Running query:8; exportSummaryToBigQuery:true;
streamTimeout:60
2018-08-03T23:17:58.522Z skipping since configuration is not implemented
2018-08-03T23:17:58.522Z Running query:9; exportSummaryToBigQuery:true;
numEvents:10000; streamTimeout:60
2018-08-03T23:17:58.522Z skipping since configuration is not implemented
2018-08-03T23:17:58.522Z Running query:10; exportSummaryToBigQuery:true;
streamTimeout:60
2018-08-03T23:17:58.522Z skipping since configuration is not implemented
2018-08-03T23:17:58.522Z Running query:11; exportSummaryToBigQuery:true;
streamTimeout:60
2018-08-03T23:17:58.522Z skipping since configuration is not implemented
2018-08-03T23:17:58.522Z Running query:12; exportSummaryToBigQuery:true;
streamTimeout:60
2018-08-03T23:17:58.522Z skipping since configuration is not implemented
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Daemon worker,5,main]) completed. Took 1
mins 31.36 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_152/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.
See
https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1m 44s
65 actionable tasks: 2 executed, 63 up-to-date
Publishing build scan...
https://gradle.com/s/yeh2xli6zwme6
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
