See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/938/display/redirect?page=changes>
Changes:
[coheigea] Move array declarations after the type
------------------------------------------
[...truncated 35.65 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)
(6/16) (3f80a29f85fc0c95e43a67e26c6908d3).
Oct 28, 2018 8:55:22 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)
60956fef3cbf3f39e5928fe57cfac2b5.
Oct 28, 2018 8:55:22 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) (3f80a29f85fc0c95e43a67e26c6908d3) [FINISHED]
Oct 28, 2018 8:55:22 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)
3f80a29f85fc0c95e43a67e26c6908d3.
Oct 28, 2018 8:55:22 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) (73d5752f1e18de62363b6549c03febfb) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (60956fef3cbf3f39e5928fe57cfac2b5) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (3f80a29f85fc0c95e43a67e26c6908d3) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (2b44a4c30342cc322f90c32ca7235654) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (2b44a4c30342cc322f90c32ca7235654).
Oct 28, 2018 8:55:22 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) (2b44a4c30342cc322f90c32ca7235654) [FINISHED]
Oct 28, 2018 8:55:22 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)
2b44a4c30342cc322f90c32ca7235654.
Oct 28, 2018 8:55:22 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) (29a291c4a3dddd9d1b2517873407d7d4) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (29a291c4a3dddd9d1b2517873407d7d4).
Oct 28, 2018 8:55:22 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) (29a291c4a3dddd9d1b2517873407d7d4) [FINISHED]
Oct 28, 2018 8:55:22 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)
(14/16) (7f557309c0ea0a4b1b1aaa1934e3a349) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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)
(14/16) (7f557309c0ea0a4b1b1aaa1934e3a349).
Oct 28, 2018 8:55:22 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)
(14/16) (7f557309c0ea0a4b1b1aaa1934e3a349) [FINISHED]
Oct 28, 2018 8:55:22 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)
29a291c4a3dddd9d1b2517873407d7d4.
Oct 28, 2018 8:55:22 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)
(13/16) (13bec60912a5490c64162d9ceec30577) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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)
(13/16) (13bec60912a5490c64162d9ceec30577).
Oct 28, 2018 8:55:22 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)
7f557309c0ea0a4b1b1aaa1934e3a349.
Oct 28, 2018 8:55:22 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)
(13/16) (13bec60912a5490c64162d9ceec30577) [FINISHED]
Oct 28, 2018 8:55:22 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) (2b44a4c30342cc322f90c32ca7235654) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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)
(2/16) (19864c6ef310247284551a251129866b) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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)
(2/16) (19864c6ef310247284551a251129866b).
Oct 28, 2018 8:55:22 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)
(2/16) (19864c6ef310247284551a251129866b) [FINISHED]
Oct 28, 2018 8:55:22 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)
13bec60912a5490c64162d9ceec30577.
Oct 28, 2018 8:55:22 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) (ee87cdbcac4446b479332fcc0aa60d75) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (ee87cdbcac4446b479332fcc0aa60d75).
Oct 28, 2018 8:55:22 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) (c9a7c806a40447716ffb13867ae3ab39) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (ee87cdbcac4446b479332fcc0aa60d75) [FINISHED]
Oct 28, 2018 8:55:22 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) (c9a7c806a40447716ffb13867ae3ab39).
Oct 28, 2018 8:55:22 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) (742e545ee70bb2ff8fe3577c64a9e987) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (cd251733ad2db92b70a6c9abe4d411f0) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (c9a7c806a40447716ffb13867ae3ab39) [FINISHED]
Oct 28, 2018 8:55:22 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) (cd251733ad2db92b70a6c9abe4d411f0).
Oct 28, 2018 8:55:22 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) (742e545ee70bb2ff8fe3577c64a9e987).
Oct 28, 2018 8:55:22 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) (cd251733ad2db92b70a6c9abe4d411f0) [FINISHED]
Oct 28, 2018 8:55:22 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) (742e545ee70bb2ff8fe3577c64a9e987) [FINISHED]
Oct 28, 2018 8:55:22 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) (29a291c4a3dddd9d1b2517873407d7d4) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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)
19864c6ef310247284551a251129866b.
Oct 28, 2018 8:55:22 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)
(15/16) (bee25d72c7006eec393453b6ac1ea950) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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)
(15/16) (bee25d72c7006eec393453b6ac1ea950).
Oct 28, 2018 8:55:22 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) (bee25d72c7006eec393453b6ac1ea950) [FINISHED]
Oct 28, 2018 8:55:22 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)
ee87cdbcac4446b479332fcc0aa60d75.
Oct 28, 2018 8:55:22 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)
(14/16) (7f557309c0ea0a4b1b1aaa1934e3a349) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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)
c9a7c806a40447716ffb13867ae3ab39.
Oct 28, 2018 8:55:22 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) (13bec60912a5490c64162d9ceec30577) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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)
cd251733ad2db92b70a6c9abe4d411f0.
Oct 28, 2018 8:55:22 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)
(2/16) (19864c6ef310247284551a251129866b) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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)
742e545ee70bb2ff8fe3577c64a9e987.
Oct 28, 2018 8:55:22 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)
bee25d72c7006eec393453b6ac1ea950.
Oct 28, 2018 8:55:22 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) (ee87cdbcac4446b479332fcc0aa60d75) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (c9a7c806a40447716ffb13867ae3ab39) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (cd251733ad2db92b70a6c9abe4d411f0) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (742e545ee70bb2ff8fe3577c64a9e987) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 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) (bee25d72c7006eec393453b6ac1ea950) switched from RUNNING to FINISHED.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1028205511-85cec5d3 (8221f3e663a95b880bc772870f1e7811)
switched from state RUNNING to FINISHED.
Oct 28, 2018 8:55:22 PM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job 8221f3e663a95b880bc772870f1e7811.
Oct 28, 2018 8:55:22 PM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 8221f3e663a95b880bc772870f1e7811 reached globally terminal state
FINISHED.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1028205511-85cec5d3(8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 8221f3e663a95b880bc772870f1e7811.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 1c39d6a3f98a4515675dde3ce5e71f70:
JobManager is shutting down..
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 28, 2018 8:55:22 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
ad5c84bff5b913c5409ca06f3a0f49c6@akka://flink/user/jobmanager_25 for job
8221f3e663a95b880bc772870f1e7811 from the resource manager.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 28, 2018 8:55:22 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 8221f3e663a95b880bc772870f1e7811 with leader id
ad5c84bff5b913c5409ca06f3a0f49c6 lost leadership.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher03ca1243-630f-41f2-9eb2-bc889e24ea96.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher03ca1243-630f-41f2-9eb2-bc889e24ea96.
Oct 28, 2018 8:55:22 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{202b3e36ab90620f3d65423cc4b0d438}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 28, 2018 8:55:22 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{e426df331f56ff07b967ffe91d624cad}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 28, 2018 8:55:22 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 5d1241333bc02182ba3e1a1bfe37be5a from the
SlotManager.
Oct 28, 2018 8:55:22 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{09a9586945063ddd7771f982a720c1ff}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{aea5a6ca9249d3b9c2c348e3a73d82d2}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{1c2edeba98c7ce58a02c7d48bd899b92}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{3aa95a929ac16839cf486e4776cc54b3}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{0e9be7939631e31acca303a0a8b90aed}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{64ce619ab6256912271a472cb3360292}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{b66def530bd524ae1c8032756de42ddd}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{4763609575518ef14dfd15b354ac0e20}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{b258cdf2969cd09214fa944e9369a7f9}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{44c51312fd6385f22a939bfbbb5530a3}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher03ca1243-630f-41f2-9eb2-bc889e24ea96.
Oct 28, 2018 8:55:22 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{aafc467ff4f64391d359e0518ad96872}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{88bd99a3beec1708dad38da9ed9a7c01}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{5548f2a22a1fb4858091d9dc69f83722}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 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{8ad418fea0c77afd6e4fc1cea6a8c3b9}, jobId:
8221f3e663a95b880bc772870f1e7811).
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 8221f3e663a95b880bc772870f1e7811 from job leader monitoring.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 8221f3e663a95b880bc772870f1e7811.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 28, 2018 8:55:22 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-0508ace4-9288-42e3-8142-19d4c17aac61
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:38393
Oct 28, 2018 8:55:22 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 28, 2018 8:55:22 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 10802 msecs
Oct 28, 2018 8:55:22 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 28, 2018 8:55:22 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@4a608eec
2018-10-28T20:55:22.971Z Waiting for main pipeline to 'finish'
2018-10-28T20:55:22.971Z DONE Query12
2018-10-28T20:55:22.971Z 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 3,5,main])
completed. Took 44.122 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 16s
68 actionable tasks: 15 executed, 53 up-to-date
Publishing build scan...
https://gradle.com/s/7kg36ot6wvjfu
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]
