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