See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/936/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)
(16/16) (fd403a2e63d32861a10a87df68ebcb2f) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (3c4cc4633f54f5a01d998eaee1d694bf) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (2feaccb6e6c2862c0a01df9d01843d13) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (82f76c5ab883a762c655f12bef109299) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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)
(8/16) (4b600532c91c3d2261f69dbbf6c9ab67) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (4b600532c91c3d2261f69dbbf6c9ab67).
Oct 28, 2018 12:15:47 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) (82f76c5ab883a762c655f12bef109299).
Oct 28, 2018 12:15:47 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) (4b600532c91c3d2261f69dbbf6c9ab67) [FINISHED]
Oct 28, 2018 12:15:47 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) (2feaccb6e6c2862c0a01df9d01843d13).
Oct 28, 2018 12:15:47 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) (a8eb0b8ecb98c64b1618afa37fab224a) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (2feaccb6e6c2862c0a01df9d01843d13) [FINISHED]
Oct 28, 2018 12:15:47 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) (82f76c5ab883a762c655f12bef109299) [FINISHED]
Oct 28, 2018 12:15:47 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) (a8eb0b8ecb98c64b1618afa37fab224a).
Oct 28, 2018 12:15:47 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)
4b600532c91c3d2261f69dbbf6c9ab67.
Oct 28, 2018 12:15:47 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) (fe0766fda6df986258bcb89eb2773fd3) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (a8eb0b8ecb98c64b1618afa37fab224a) [FINISHED]
Oct 28, 2018 12:15:47 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) (fe0766fda6df986258bcb89eb2773fd3).
Oct 28, 2018 12:15:47 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) (fe0766fda6df986258bcb89eb2773fd3) [FINISHED]
Oct 28, 2018 12:15:47 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) (5549e10c0367ccb56e5b02c734af1700) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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)
2feaccb6e6c2862c0a01df9d01843d13.
Oct 28, 2018 12:15:47 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) (5549e10c0367ccb56e5b02c734af1700).
Oct 28, 2018 12:15:47 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) (5549e10c0367ccb56e5b02c734af1700) [FINISHED]
Oct 28, 2018 12:15:47 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) (fe8a8f2fcb9c3d9682a10a468a1ee8cc) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (fe8a8f2fcb9c3d9682a10a468a1ee8cc).
Oct 28, 2018 12:15:47 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) (fe8a8f2fcb9c3d9682a10a468a1ee8cc) [FINISHED]
Oct 28, 2018 12:15:47 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)
82f76c5ab883a762c655f12bef109299.
Oct 28, 2018 12:15:47 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) (4b600532c91c3d2261f69dbbf6c9ab67) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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)
a8eb0b8ecb98c64b1618afa37fab224a.
Oct 28, 2018 12:15:47 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)
fe0766fda6df986258bcb89eb2773fd3.
Oct 28, 2018 12:15:47 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) (2feaccb6e6c2862c0a01df9d01843d13) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (6c7ded33bc2117bfa69540556ed64b95) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (6c7ded33bc2117bfa69540556ed64b95).
Oct 28, 2018 12:15:47 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) (6c7ded33bc2117bfa69540556ed64b95) [FINISHED]
Oct 28, 2018 12:15:47 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)
5549e10c0367ccb56e5b02c734af1700.
Oct 28, 2018 12:15:47 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)
fe8a8f2fcb9c3d9682a10a468a1ee8cc.
Oct 28, 2018 12:15:47 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) (82f76c5ab883a762c655f12bef109299) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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)
6c7ded33bc2117bfa69540556ed64b95.
Oct 28, 2018 12:15:47 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) (a8eb0b8ecb98c64b1618afa37fab224a) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (fe0766fda6df986258bcb89eb2773fd3) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (5549e10c0367ccb56e5b02c734af1700) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (fe8a8f2fcb9c3d9682a10a468a1ee8cc) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (6c7ded33bc2117bfa69540556ed64b95) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (bd0d54cd371f605eae99e35cdc479fc8) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (bd0d54cd371f605eae99e35cdc479fc8).
Oct 28, 2018 12:15:47 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) (bd0d54cd371f605eae99e35cdc479fc8) [FINISHED]
Oct 28, 2018 12:15:47 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) (7fd85ed5ba2e76c410752cf4b0b9d8fb) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (7fd85ed5ba2e76c410752cf4b0b9d8fb).
Oct 28, 2018 12:15:47 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)
bd0d54cd371f605eae99e35cdc479fc8.
Oct 28, 2018 12:15:47 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) (7fd85ed5ba2e76c410752cf4b0b9d8fb) [FINISHED]
Oct 28, 2018 12:15:47 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)
7fd85ed5ba2e76c410752cf4b0b9d8fb.
Oct 28, 2018 12:15:47 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) (bd0d54cd371f605eae99e35cdc479fc8) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (7fd85ed5ba2e76c410752cf4b0b9d8fb) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (c98e5c3ce1ff2aab6fc18893698a3369) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 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) (c98e5c3ce1ff2aab6fc18893698a3369).
Oct 28, 2018 12:15:47 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) (c98e5c3ce1ff2aab6fc18893698a3369) [FINISHED]
Oct 28, 2018 12:15:47 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)
c98e5c3ce1ff2aab6fc18893698a3369.
Oct 28, 2018 12:15:47 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) (c98e5c3ce1ff2aab6fc18893698a3369) switched from RUNNING to FINISHED.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1028121536-b7050f50 (b284c61b6ec0d9af99b981105dde12c7)
switched from state RUNNING to FINISHED.
Oct 28, 2018 12:15:47 PM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job b284c61b6ec0d9af99b981105dde12c7.
Oct 28, 2018 12:15:47 PM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job b284c61b6ec0d9af99b981105dde12c7 reached globally terminal state
FINISHED.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1028121536-b7050f50(b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job b284c61b6ec0d9af99b981105dde12c7.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection b5568c568d91b9ecd50ec675405f8917:
JobManager is shutting down..
Oct 28, 2018 12:15:47 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
a763a85088b2e04ad63eddcaaf674746@akka://flink/user/jobmanager_25 for job
b284c61b6ec0d9af99b981105dde12c7 from the resource manager.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher5cfab2b7-6e90-452e-8941-7a76ebc73a5d.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher5cfab2b7-6e90-452e-8941-7a76ebc73a5d.
Oct 28, 2018 12:15:47 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job b284c61b6ec0d9af99b981105dde12c7 with leader id
a763a85088b2e04ad63eddcaaf674746 lost leadership.
Oct 28, 2018 12:15:47 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 28, 2018 12:15:47 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 28, 2018 12:15:47 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager e05944cb672f2de9c0396905f903dca7 from the
SlotManager.
Oct 28, 2018 12:15:47 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{f2da7ae29efc9d86b3b10a8edbfed6d9}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{75f32fa7211ead8ef5e6780eae491e34}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{5a3bb3ac3e3760ac5f27669e5ca60f82}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{9b082455311a294f43dea816f0db608d}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{7c59d431aedc1b267a6cd7a85d8c661b}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{d1febcf2f2db7cd2f20d1d1b9ec53361}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{d6860a08aa45db9a70c16782a9694f38}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{8d84dd7feec1975dd4cdbe571c5f8ebe}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{b08f77a0fedacede982556f2fa680596}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{7f8aa5b80ecb5cd90aceb29fa2d93af7}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{255bdaeebaba12f5810eb68b0fd1ecd5}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{34f3c8f4f5e0567edbd0da9887035539}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{39b208f72bddb8e607041df9b40ab3f0}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{6a8e18ea3da6061a29d54ddd1c1408f7}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{90ca35bf7a67e470247c1a2b3a6b6aed}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 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{9e8088db9cbb1a3b810169d6b6a68874}, jobId:
b284c61b6ec0d9af99b981105dde12c7).
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job b284c61b6ec0d9af99b981105dde12c7 from job leader monitoring.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job b284c61b6ec0d9af99b981105dde12c7.
Oct 28, 2018 12:15:47 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher5cfab2b7-6e90-452e-8941-7a76ebc73a5d.
Oct 28, 2018 12:15:47 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-c01860f0-d573-4b48-8e82-b463230361e4
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:39521
Oct 28, 2018 12:15:47 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 28, 2018 12:15:47 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 10870 msecs
Oct 28, 2018 12:15:47 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 28, 2018 12:15:47 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@94e79137
2018-10-28T12:15:47.708Z Waiting for main pipeline to 'finish'
2018-10-28T12:15:47.708Z DONE Query12
2018-10-28T12:15:47.708Z 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 ':',5,main]) completed.
Took 45.511 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/5ubjvmncljb3o
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]
