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-unsubscr...@beam.apache.org For additional commands, e-mail: builds-h...@beam.apache.org