See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/1551/display/redirect?page=changes>
Changes: [github] Revert "[BEAM-4780] Updating to DockerJobBundleFactory in ------------------------------------------ [...truncated 761.28 MB...] INFO: Freeing task resources for GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (10/16) (f48915eccc4525b3b0337b3ba9a47a73). Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (6/16) (f6511880c20ebd84d7531c76809351ba) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Ensuring all FileSystem streams are closed for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (10/16) (f48915eccc4525b3b0337b3ba9a47a73) [FINISHED] Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Freeing task resources for GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (6/16) (f6511880c20ebd84d7531c76809351ba). Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: Source: GenerateSequence/Read(UnboundedCountingSource)/Create/Read(CreateSource) -> GenerateSequence/Read(UnboundedCountingSource)/Split/ParMultiDo(Split) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Pair with random key/ParMultiDo(AssignShard) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/Window.Into()/Window.Assign.out -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/16) (a6729680606a3adf9970a7d124cf88c3) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Ensuring all FileSystem streams are closed for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (6/16) (f6511880c20ebd84d7531c76809351ba) [FINISHED] Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/16) (f02dbcca2f95f9c13b60b3de108e8e41) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) ba88347e124740e08e4b482720a29ea9. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Freeing task resources for GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/16) (f02dbcca2f95f9c13b60b3de108e8e41). Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Ensuring all FileSystem streams are closed for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/16) (f02dbcca2f95f9c13b60b3de108e8e41) [FINISHED] Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Freeing task resources for GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (7/16) (e7210f26f8d9ac8160901af2e91d7ed6). Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Ensuring all FileSystem streams are closed for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (7/16) (e7210f26f8d9ac8160901af2e91d7ed6) [FINISHED] Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (16/16) (a69a6bc6f5ce75d8012f0bac8e047d25) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) 32fab9d33cb5fd887f1fec1dc69ed02c. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (3/16) (ba88347e124740e08e4b482720a29ea9) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) 4ba21c0c92ca7511ada6a6cc842b9457. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (9/16) (32fab9d33cb5fd887f1fec1dc69ed02c) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) 03f583556df222953a859fe9da04a8f3. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) d6a329d050ab2c1737a3f29920d18b93. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (12/16) (4ba21c0c92ca7511ada6a6cc842b9457) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) a81e83210fbf0b01e07552dca9234249. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (11/16) (03f583556df222953a859fe9da04a8f3) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) e458467b3b9d82f3aff8fcec82156b0d. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) 325404a406661cdcec03afc65ae5c589. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (8/16) (d6a329d050ab2c1737a3f29920d18b93) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) ff430e259ce2f675892749f2c4bdc67f. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (4/16) (a81e83210fbf0b01e07552dca9234249) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) f48915eccc4525b3b0337b3ba9a47a73. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (13/16) (e458467b3b9d82f3aff8fcec82156b0d) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) f6511880c20ebd84d7531c76809351ba. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (2/16) (325404a406661cdcec03afc65ae5c589) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) f02dbcca2f95f9c13b60b3de108e8e41. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (15/16) (ff430e259ce2f675892749f2c4bdc67f) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) e7210f26f8d9ac8160901af2e91d7ed6. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (10/16) (f48915eccc4525b3b0337b3ba9a47a73) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (6/16) (f6511880c20ebd84d7531c76809351ba) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/16) (f02dbcca2f95f9c13b60b3de108e8e41) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (7/16) (e7210f26f8d9ac8160901af2e91d7ed6) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (14/16) (668c9237f6b81532d9a70aabe9a3c326) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Freeing task resources for GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (14/16) (668c9237f6b81532d9a70aabe9a3c326). Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Ensuring all FileSystem streams are closed for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (14/16) (668c9237f6b81532d9a70aabe9a3c326) [FINISHED] Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) 668c9237f6b81532d9a70aabe9a3c326. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (14/16) (668c9237f6b81532d9a70aabe9a3c326) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (5/16) (6ca9ba1717783c35b79d6384b22c10b3) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Freeing task resources for GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (5/16) (6ca9ba1717783c35b79d6384b22c10b3). Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Ensuring all FileSystem streams are closed for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (5/16) (6ca9ba1717783c35b79d6384b22c10b3) [FINISHED] Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) 6ca9ba1717783c35b79d6384b22c10b3. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (5/16) (6ca9ba1717783c35b79d6384b22c10b3) switched from RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState INFO: Job metricspushertest0test-jenkins-0920020526-4fd86a26 (99937e7ce28715a38e9f8a9957765d17) switched from state RUNNING to FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown INFO: Stopping checkpoint coordinator for job 99937e7ce28715a38e9f8a9957765d17. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown INFO: Shutting down Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState INFO: Job 99937e7ce28715a38e9f8a9957765d17 reached globally terminal state FINISHED. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.jobmaster.JobMaster postStop INFO: Stopping the JobMaster for job metricspushertest0test-jenkins-0920020526-4fd86a26(99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection INFO: Close JobManager connection for job 99937e7ce28715a38e9f8a9957765d17. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection INFO: Close ResourceManager connection 81b4346fc788b4e132eda1e92af411c4: JobManager is shutting down.. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend INFO: Suspending SlotPool. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.minicluster.MiniCluster closeAsync INFO: Shutting down Flink Mini Cluster Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop INFO: Stopping SlotPool. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection INFO: Disconnect job manager 84707484b84c49e4d2feec049e054efa@akka://flink/user/jobmanager_313 for job 99937e7ce28715a38e9f8a9957765d17 from the resource manager. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop INFO: Stopping dispatcher akka://flink/user/dispatcher8eaa3988-d662-4394-a6b7-1f61401abcfd. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync INFO: Shutting down rest endpoint. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher8eaa3988-d662-4394-a6b7-1f61401abcfd. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership INFO: JobManager for job 99937e7ce28715a38e9f8a9957765d17 with leader id 84707484b84c49e4d2feec049e054efa lost leadership. Sep 20, 2018 2:05:27 AM 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{b94e2e714d0b2ea7d0c2f8cccc00ab6b}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close INFO: Closing the SlotManager. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend INFO: Suspending the SlotManager. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager unregisterTaskManager INFO: Unregister TaskManager cc461825cfe419e2048ebbe0644105a7 from the SlotManager. Sep 20, 2018 2:05:27 AM 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{72d978d1d017b3642e56d712753e9fa0}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{51135ad190e1c249fd446ebc5d521c0b}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{f659c2e6d67427921a35dd6ea0386c44}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{d986eea7b71bc5b9f5b2184da50aa0c0}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{ee784e2d6cf645fd287ebc455bd118fc}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{b31b2959025e568f9b2441826c4d302b}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{597895acbc5dacbdf8953a21513b1a64}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{4dc7288367c346f44c92a2485e743bb8}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{459ad764c351e24ed67fa58bcb0101ef}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{511a834f491b77873cfa542b01980f67}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{559b8d9a2a674f24854a184fb3dc4926}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{fb4bf6883246a9f7c125aef7db07ccc5}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{7c01cb6622539ad78f691f829baedb46}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{42f58ff33067e38e870e3a60874a11a4}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM 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{1a488a1f6330abd42ecb257ac410dfa1}, jobId: 99937e7ce28715a38e9f8a9957765d17). Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob INFO: Remove job 99937e7ce28715a38e9f8a9957765d17 from job leader monitoring. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection INFO: Close JobManager connection for job 99937e7ce28715a38e9f8a9957765d17. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop INFO: Stopping TaskExecutor akka://flink/user/taskmanager_312. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown INFO: Shutting down TaskExecutorLocalStateStoresManager. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown INFO: I/O manager removed spill file directory /tmp/flink-io-46cface6-0fe6-461f-b2e2-7e56f4fb2c3b Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown INFO: Shutting down stack trace sample coordinator. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown INFO: Shutting down the network environment and its components. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0 INFO: Stopped dispatcher akka://flink/user/dispatcher8eaa3988-d662-4394-a6b7-1f61401abcfd. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.JobLeaderService stop INFO: Stop job leader service. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop INFO: Stopped TaskExecutor akka://flink/user/taskmanager_312. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4 INFO: Removing cache directory /tmp/flink-web-ui Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService INFO: Stopping Akka RPC service. Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.blob.AbstractBlobCache close INFO: Shutting down BLOB cache Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.blob.AbstractBlobCache close INFO: Shutting down BLOB cache Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.blob.BlobServer close INFO: Stopped BLOB server at 0.0.0.0:39197 Sep 20, 2018 2:05:27 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4 INFO: Stopped Akka RPC service. Sep 20, 2018 2:05:27 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: Execution finished in 405 msecs Sep 20, 2018 2:05:27 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: Final accumulator values: Sep 20, 2018 2:05:27 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@1e342b Gradle Test Executor 3 finished executing tests. > Task :beam-runners-flink_2.11:validatesRunnerStreaming 242 tests completed, 2 failed, 2 skipped Finished generating test XML results (0.613 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/test-results/validatesRunnerStreaming> Generating HTML test report... Finished generating test html results (0.623 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/reports/tests/validatesRunnerStreaming> > Task :beam-runners-flink_2.11:validatesRunnerStreaming FAILED :beam-runners-flink_2.11:validatesRunnerStreaming (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 4 mins 19.949 secs. FAILURE: Build completed with 2 failures. 1: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':beam-runners-flink_2.11:validatesRunnerBatch'. > There were failing tests. See the report at: > file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/reports/tests/validatesRunnerBatch/index.html> * 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. ============================================================================== 2: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':beam-runners-flink_2.11:validatesRunnerStreaming'. > There were failing tests. See the report at: > file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/reports/tests/validatesRunnerStreaming/index.html> * 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. See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 22m 52s 47 actionable tasks: 43 executed, 4 from cache Publishing build scan... https://gradle.com/s/uen44kcb2536e Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure