See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/937/display/redirect>
------------------------------------------
[...truncated 35.66 MB...]
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(15/16) (22b283385269ca503b515297921cf65c).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
ed5d941d5d5419ad83b2d205394b6382.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(15/16) (22b283385269ca503b515297921cf65c) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(8/16) (12c59af5be81ab3544baa380458d1b64).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(3/16) (f5bb33594f5b424b26ec56f5ceb59cc6) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(9/16) (3ec5fd889cc747ea0da2b4bfb3e6da20) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(3/16) (f5bb33594f5b424b26ec56f5ceb59cc6).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(6/16) (cbda808a3696bbd7f41a08433ad81281) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(8/16) (12c59af5be81ab3544baa380458d1b64) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(6/16) (cbda808a3696bbd7f41a08433ad81281).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(3/16) (f5bb33594f5b424b26ec56f5ceb59cc6) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(6/16) (cbda808a3696bbd7f41a08433ad81281) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(10/16) (180d547dc15df32d3035f0ce33cc5e04) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(5/16) (595a602e4be47d05de898a054997551d) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(9/16) (3ec5fd889cc747ea0da2b4bfb3e6da20).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(5/16) (595a602e4be47d05de898a054997551d).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(9/16) (3ec5fd889cc747ea0da2b4bfb3e6da20) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(10/16) (180d547dc15df32d3035f0ce33cc5e04).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(5/16) (595a602e4be47d05de898a054997551d) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
a4bf400433fbd32a0ea91824b95d3e1d.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(10/16) (180d547dc15df32d3035f0ce33cc5e04) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
22b283385269ca503b515297921cf65c.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(13/16) (ed5d941d5d5419ad83b2d205394b6382) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
12c59af5be81ab3544baa380458d1b64.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(1/16) (a4bf400433fbd32a0ea91824b95d3e1d) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
f5bb33594f5b424b26ec56f5ceb59cc6.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
cbda808a3696bbd7f41a08433ad81281.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(15/16) (22b283385269ca503b515297921cf65c) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
3ec5fd889cc747ea0da2b4bfb3e6da20.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(8/16) (12c59af5be81ab3544baa380458d1b64) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
595a602e4be47d05de898a054997551d.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
180d547dc15df32d3035f0ce33cc5e04.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(3/16) (f5bb33594f5b424b26ec56f5ceb59cc6) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(6/16) (cbda808a3696bbd7f41a08433ad81281) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(9/16) (3ec5fd889cc747ea0da2b4bfb3e6da20) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(5/16) (595a602e4be47d05de898a054997551d) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(10/16) (180d547dc15df32d3035f0ce33cc5e04) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(11/16) (ef3c26d151f6084a27cb0a97339f8123) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(11/16) (ef3c26d151f6084a27cb0a97339f8123).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(12/16) (d87488f509de283d497a6dd7da9db492) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(11/16) (ef3c26d151f6084a27cb0a97339f8123) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(4/16) (5e1686679f5cc3488b82f00fb6f73d00) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(4/16) (5e1686679f5cc3488b82f00fb6f73d00).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(7/16) (88f4e83f40ad7ec4e4a3d6522714c4f0) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(4/16) (5e1686679f5cc3488b82f00fb6f73d00) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(7/16) (88f4e83f40ad7ec4e4a3d6522714c4f0).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(12/16) (d87488f509de283d497a6dd7da9db492).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
ef3c26d151f6084a27cb0a97339f8123.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(7/16) (88f4e83f40ad7ec4e4a3d6522714c4f0) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(12/16) (d87488f509de283d497a6dd7da9db492) [FINISHED]
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
5e1686679f5cc3488b82f00fb6f73d00.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
88f4e83f40ad7ec4e4a3d6522714c4f0.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(11/16) (ef3c26d151f6084a27cb0a97339f8123) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
d87488f509de283d497a6dd7da9db492.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(4/16) (5e1686679f5cc3488b82f00fb6f73d00) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(7/16) (88f4e83f40ad7ec4e4a3d6522714c4f0) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(12/16) (d87488f509de283d497a6dd7da9db492) switched from RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1028181540-aa3b25f4 (cb33e9f5fc1afa62111284d667dd557a)
switched from state RUNNING to FINISHED.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job cb33e9f5fc1afa62111284d667dd557a.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job cb33e9f5fc1afa62111284d667dd557a reached globally terminal state
FINISHED.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1028181540-aa3b25f4(cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job cb33e9f5fc1afa62111284d667dd557a.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 992a172c43a5c2a78f99084f91aa1366:
JobManager is shutting down..
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
900e856238661e0b479ac38efeb143c6@akka://flink/user/jobmanager_25 for job
cb33e9f5fc1afa62111284d667dd557a from the resource manager.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{f61b1fde992d7609ea8229645a29422e}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcherfcbc6a54-7163-45b6-9833-70c38e0aee62.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job cb33e9f5fc1afa62111284d667dd557a with leader id
900e856238661e0b479ac38efeb143c6 lost leadership.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcherfcbc6a54-7163-45b6-9833-70c38e0aee62.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{36af0fa76fa8dcbf99d5a85217da2057}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{32394395c12a529d4e2a56a827548a14}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{95e993b3aa984b4427cff79075542063}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{20f7741153c332c2deca90eb9a1f0b59}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{406390a6650e18750695777ab983b025}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{09d449ac27bc0f8a40a848cd754f2870}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{dc02770f1f2fd31f7c5cafa7e606dcd0}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager cba0fbee0facff840d0ee2f357f964a2 from the
SlotManager.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{d8882fe7a992e8205ff7468c2cacd438}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{a703f49ab45c5c8ff68491fafff04e77}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{d10f45347dfd2f5b05071fe972311dc4}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{fb5c27178f9ef302e674d119ef0066ba}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{b951bc8386e6c9c327b5b4779800be42}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{7bf38b1fce5718e3f851260d53ae7ee5}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{9bc6ceedd0fa513b0f9bc1a944453657}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 28, 2018 6:15:51 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{d34dfb7f6ec334eecc363be09e154a23}, jobId:
cb33e9f5fc1afa62111284d667dd557a).
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcherfcbc6a54-7163-45b6-9833-70c38e0aee62.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job cb33e9f5fc1afa62111284d667dd557a from job leader monitoring.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job cb33e9f5fc1afa62111284d667dd557a.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 28, 2018 6:15:51 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-cbc4c384-1d7f-48c0-a4c7-56edc9607ae7
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:40721
Oct 28, 2018 6:15:51 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 28, 2018 6:15:51 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 10797 msecs
Oct 28, 2018 6:15:51 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 28, 2018 6:15:51 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@d67b8e38
2018-10-28T18:15:51.535Z Waiting for main pipeline to 'finish'
2018-10-28T18:15:51.535Z DONE Query12
2018-10-28T18:15:51.535Z 1 samples not enough to calculate steady-state event
rate
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 4,5,main])
completed. Took 44.827 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_172/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 17s
68 actionable tasks: 15 executed, 53 up-to-date
Publishing build scan...
https://gradle.com/s/we5s7grjk2nqe
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org
