See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/934/display/redirect>
------------------------------------------
[...truncated 35.76 MB...]
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) (4c71b839c6058d70f662be7351605792) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
(2/16) (34f989370d7d837fe7cbc03bed0f3efc) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (88aaa11ce169a35a02999122c38ca31b) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (4c71b839c6058d70f662be7351605792).
Oct 28, 2018 12:15:56 AM 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)
(2/16) (34f989370d7d837fe7cbc03bed0f3efc).
Oct 28, 2018 12:15:56 AM 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) (4c71b839c6058d70f662be7351605792) [FINISHED]
Oct 28, 2018 12:15:56 AM 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)
(2/16) (34f989370d7d837fe7cbc03bed0f3efc) [FINISHED]
Oct 28, 2018 12:15:56 AM 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)
4c71b839c6058d70f662be7351605792.
Oct 28, 2018 12:15:56 AM 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) (e8cee353e7358ca7464b35bf87daaac9) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
34f989370d7d837fe7cbc03bed0f3efc.
Oct 28, 2018 12:15:56 AM 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) (4c71b839c6058d70f662be7351605792) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
(2/16) (34f989370d7d837fe7cbc03bed0f3efc) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (0b73444d639a6946a971d863faf545f4) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
(15/16) (ca57eb2bf3189ba875c95413425a1e2e) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
(16/16) (d75e5944f77ce055b613893469d5361e) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
(15/16) (ca57eb2bf3189ba875c95413425a1e2e).
Oct 28, 2018 12:15:56 AM 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) (02fb323f954faea554310da6e4a27eea) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
(13/16) (b8b75f40f0d84661fd3a19819584f7e5) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (ca57eb2bf3189ba875c95413425a1e2e) [FINISHED]
Oct 28, 2018 12:15:56 AM 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) (02fb323f954faea554310da6e4a27eea).
Oct 28, 2018 12:15:56 AM 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)
(16/16) (d75e5944f77ce055b613893469d5361e).
Oct 28, 2018 12:15:56 AM 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) (02fb323f954faea554310da6e4a27eea) [FINISHED]
Oct 28, 2018 12:15:56 AM 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)
(14/16) (6846c7d4e97c17647b14ae97f77c87ea) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (0b73444d639a6946a971d863faf545f4).
Oct 28, 2018 12:15:56 AM 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)
(14/16) (6846c7d4e97c17647b14ae97f77c87ea).
Oct 28, 2018 12:15:56 AM 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)
ca57eb2bf3189ba875c95413425a1e2e.
Oct 28, 2018 12:15:56 AM 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)
(14/16) (6846c7d4e97c17647b14ae97f77c87ea) [FINISHED]
Oct 28, 2018 12:15:56 AM 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)
(16/16) (d75e5944f77ce055b613893469d5361e) [FINISHED]
Oct 28, 2018 12:15:56 AM 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)
(13/16) (b8b75f40f0d84661fd3a19819584f7e5).
Oct 28, 2018 12:15:56 AM 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) (0b73444d639a6946a971d863faf545f4) [FINISHED]
Oct 28, 2018 12:15:56 AM 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)
(13/16) (b8b75f40f0d84661fd3a19819584f7e5) [FINISHED]
Oct 28, 2018 12:15:56 AM 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)
02fb323f954faea554310da6e4a27eea.
Oct 28, 2018 12:15:56 AM 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)
6846c7d4e97c17647b14ae97f77c87ea.
Oct 28, 2018 12:15:56 AM 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) (ca57eb2bf3189ba875c95413425a1e2e) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
d75e5944f77ce055b613893469d5361e.
Oct 28, 2018 12:15:56 AM 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) (286e9293e1118882b6acc6b05b550bad) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (286e9293e1118882b6acc6b05b550bad).
Oct 28, 2018 12:15:56 AM 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) (286e9293e1118882b6acc6b05b550bad) [FINISHED]
Oct 28, 2018 12:15:56 AM 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) (02fb323f954faea554310da6e4a27eea) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
0b73444d639a6946a971d863faf545f4.
Oct 28, 2018 12:15:56 AM 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)
b8b75f40f0d84661fd3a19819584f7e5.
Oct 28, 2018 12:15:56 AM 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)
(14/16) (6846c7d4e97c17647b14ae97f77c87ea) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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)
286e9293e1118882b6acc6b05b550bad.
Oct 28, 2018 12:15:56 AM 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) (3f8ac5dae66c810ec277f24f9ac83e63) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (3f8ac5dae66c810ec277f24f9ac83e63).
Oct 28, 2018 12:15:56 AM 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)
(16/16) (d75e5944f77ce055b613893469d5361e) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (3f8ac5dae66c810ec277f24f9ac83e63) [FINISHED]
Oct 28, 2018 12:15:56 AM 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)
3f8ac5dae66c810ec277f24f9ac83e63.
Oct 28, 2018 12:15:56 AM 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) (39c248cecacc8c1854dbe9bb66e67156) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (39c248cecacc8c1854dbe9bb66e67156).
Oct 28, 2018 12:15:56 AM 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) (39c248cecacc8c1854dbe9bb66e67156) [FINISHED]
Oct 28, 2018 12:15:56 AM 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)
39c248cecacc8c1854dbe9bb66e67156.
Oct 28, 2018 12:15:56 AM 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) (0b73444d639a6946a971d863faf545f4) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (b8b75f40f0d84661fd3a19819584f7e5) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (286e9293e1118882b6acc6b05b550bad) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (3f8ac5dae66c810ec277f24f9ac83e63) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM 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) (39c248cecacc8c1854dbe9bb66e67156) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1028001544-4fcd6863 (8586e38e1725509abd175ac3a40eb6b5)
switched from state RUNNING to FINISHED.
Oct 28, 2018 12:15:56 AM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job 8586e38e1725509abd175ac3a40eb6b5.
Oct 28, 2018 12:15:56 AM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 8586e38e1725509abd175ac3a40eb6b5 reached globally terminal state
FINISHED.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1028001544-4fcd6863(8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 8586e38e1725509abd175ac3a40eb6b5.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 1d9dedcf35c6ad29f087be1982640199:
JobManager is shutting down..
Oct 28, 2018 12:15:56 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
8c4a4a128a2496b754d6eb325f3b471d@akka://flink/user/jobmanager_25 for job
8586e38e1725509abd175ac3a40eb6b5 from the resource manager.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatchere645796e-ba59-4c59-8154-31b31b338ac2.
Oct 28, 2018 12:15:56 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 8586e38e1725509abd175ac3a40eb6b5 with leader id
8c4a4a128a2496b754d6eb325f3b471d lost leadership.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatchere645796e-ba59-4c59-8154-31b31b338ac2.
Oct 28, 2018 12:15:56 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 28, 2018 12:15:56 AM
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{84a167280de0d9483ea6d980dc8fd4ee}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 28, 2018 12:15:56 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager b897d57f0cc46ceada33e2ff48835c64 from the
SlotManager.
Oct 28, 2018 12:15:56 AM
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{b9fbcad8691e3ee762e786d7997e3ced}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{b02ae7ba09ec4edd26e85afca02c8a7e}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 28, 2018 12:15:56 AM
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{4be72b2fed01f9f1766f233d5217658d}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatchere645796e-ba59-4c59-8154-31b31b338ac2.
Oct 28, 2018 12:15:56 AM
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{dedb04ddc136dc316f79862f9701b873}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{298725f604186a1e26254a7592b32bd6}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{c251d4c45184e8d618b170d1eb8706fb}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{64f57a42e0993a3ae99613b7872be5cd}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{7aad8aa15b32876a687aac23691f2ed4}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{7e10c97cbe498322faec1dae8d23b9d3}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{6426cd31a8ab155c8bd01ad4683fbccf}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{41ff26215534a2bc400894eb44286ac7}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{b6ba4d8b1c683d2b3a7fa35bcbee9a7b}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{bd7a664d401eb8c0499ead7bd21c93db}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{f3aee5803d25a82d7fc3a8acb74eab86}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM
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{998aa109bc6bc8fa2084478f79d87b1f}, jobId:
8586e38e1725509abd175ac3a40eb6b5).
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 8586e38e1725509abd175ac3a40eb6b5 from job leader monitoring.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 8586e38e1725509abd175ac3a40eb6b5.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 28, 2018 12:15:56 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-90d1a470-32cc-40fc-99a7-95cd3395e211
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:46335
Oct 28, 2018 12:15:56 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 28, 2018 12:15:56 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 10752 msecs
Oct 28, 2018 12:15:56 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 28, 2018 12:15:56 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@8dfad1cd
2018-10-28T00:15:56.210Z Waiting for main pipeline to 'finish'
2018-10-28T00:15:56.210Z DONE Query12
2018-10-28T00:15:56.210Z 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 6,5,main])
completed. Took 45.065 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 19s
68 actionable tasks: 15 executed, 53 up-to-date
Publishing build scan...
https://gradle.com/s/h4nqqkq2snqb6
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
