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