See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/1563/display/redirect?page=changes>
Changes: [scott] Ensure all pre-commits are run on gradle upgrade. ------------------------------------------ [...truncated 762.32 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) (9/16) (aa61c052006ee5179251a58326e82e95). Sep 20, 2018 10:02:52 PM 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) (6cd0a12f80b9fb36873e48d751f1ade6) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (3/16) (531d4cfc4f4e0a9fc0d8a58bbdb5ff64) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (6cd0a12f80b9fb36873e48d751f1ade6). Sep 20, 2018 10:02:52 PM 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) (3/16) (531d4cfc4f4e0a9fc0d8a58bbdb5ff64). Sep 20, 2018 10:02:52 PM 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) (6cd0a12f80b9fb36873e48d751f1ade6) [FINISHED] Sep 20, 2018 10:02:52 PM 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) (3/16) (531d4cfc4f4e0a9fc0d8a58bbdb5ff64) [FINISHED] Sep 20, 2018 10:02:52 PM 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) 3cd756be9846f71acd7d943aceab9606. Sep 20, 2018 10:02:52 PM 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) (2/16) (28ca3629ffa164eb363410d0a63daeff). Sep 20, 2018 10:02:52 PM 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) (12/16) (44a6b9c8bc89e507786e6f6ebdbd52eb) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (2/16) (28ca3629ffa164eb363410d0a63daeff) [FINISHED] Sep 20, 2018 10:02:52 PM 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) (12/16) (44a6b9c8bc89e507786e6f6ebdbd52eb). Sep 20, 2018 10:02:52 PM 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) (9/16) (aa61c052006ee5179251a58326e82e95) [FINISHED] Sep 20, 2018 10:02:52 PM 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) (33ea147ff751777217738ca43d3a9882) [FINISHED] Sep 20, 2018 10:02:52 PM 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) (513ebcb5dbe45743444d8209187f15cd) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) a5d85aa3c5073d8f7f5e5981f2a0e3a3. Sep 20, 2018 10:02:52 PM 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) (12/16) (44a6b9c8bc89e507786e6f6ebdbd52eb) [FINISHED] Sep 20, 2018 10:02:52 PM 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) a0ed92b5d020be7881569db6eb877897. Sep 20, 2018 10:02:52 PM 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) (3cd756be9846f71acd7d943aceab9606) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) e5ad0e44adc5ef835af0853d3fd0064a. Sep 20, 2018 10:02:52 PM 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) (a5d85aa3c5073d8f7f5e5981f2a0e3a3) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) bd4797468eebf05e060b2bf7772a8e22. Sep 20, 2018 10:02:52 PM 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) (a0ed92b5d020be7881569db6eb877897) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) b432e5e782a0d8d29d2475508057e76d. Sep 20, 2018 10:02:52 PM 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) 82f604837aa509070b8ef9e4a31af006. Sep 20, 2018 10:02:52 PM 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) 72199773127d071ce066ea3be15b22e4. Sep 20, 2018 10:02:52 PM 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) 5b9a52367bfb268ce6551e0e3a2e56c6. Sep 20, 2018 10:02:52 PM 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) (e5ad0e44adc5ef835af0853d3fd0064a) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) 842981b770cacad91c951b254bcf312f. Sep 20, 2018 10:02:52 PM 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) (bd4797468eebf05e060b2bf7772a8e22) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) 6cd0a12f80b9fb36873e48d751f1ade6. Sep 20, 2018 10:02:52 PM 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) 531d4cfc4f4e0a9fc0d8a58bbdb5ff64. Sep 20, 2018 10:02:52 PM 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) (b432e5e782a0d8d29d2475508057e76d) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) 28ca3629ffa164eb363410d0a63daeff. Sep 20, 2018 10:02:52 PM 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) aa61c052006ee5179251a58326e82e95. Sep 20, 2018 10:02:52 PM 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) (82f604837aa509070b8ef9e4a31af006) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) 33ea147ff751777217738ca43d3a9882. Sep 20, 2018 10:02:52 PM 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) (72199773127d071ce066ea3be15b22e4) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) 44a6b9c8bc89e507786e6f6ebdbd52eb. Sep 20, 2018 10:02:52 PM 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) (5b9a52367bfb268ce6551e0e3a2e56c6) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (842981b770cacad91c951b254bcf312f) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (6cd0a12f80b9fb36873e48d751f1ade6) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (531d4cfc4f4e0a9fc0d8a58bbdb5ff64) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (28ca3629ffa164eb363410d0a63daeff) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (aa61c052006ee5179251a58326e82e95) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (33ea147ff751777217738ca43d3a9882) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM 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) (44a6b9c8bc89e507786e6f6ebdbd52eb) switched from RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState INFO: Job metricspushertest0test-jenkins-0920220251-a116f05a (7e1e34fba0216e8b081b0b03915d25b8) switched from state RUNNING to FINISHED. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown INFO: Stopping checkpoint coordinator for job 7e1e34fba0216e8b081b0b03915d25b8. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown INFO: Shutting down Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState INFO: Job 7e1e34fba0216e8b081b0b03915d25b8 reached globally terminal state FINISHED. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.jobmaster.JobMaster postStop INFO: Stopping the JobMaster for job metricspushertest0test-jenkins-0920220251-a116f05a(7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection INFO: Close JobManager connection for job 7e1e34fba0216e8b081b0b03915d25b8. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection INFO: Close ResourceManager connection d02d59a618c2cc29e98fa195f86a5749: JobManager is shutting down.. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend INFO: Suspending SlotPool. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.minicluster.MiniCluster closeAsync INFO: Shutting down Flink Mini Cluster Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection INFO: Disconnect job manager b9a4be5a26d08b3addd91c23cf91496a@akka://flink/user/jobmanager_313 for job 7e1e34fba0216e8b081b0b03915d25b8 from the resource manager. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop INFO: Stopping SlotPool. Sep 20, 2018 10:02:52 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{96e8722a63d80430b7f196c58ff04a62}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync INFO: Shutting down rest endpoint. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$1 INFO: Could not resolve JobManager address akka://flink/user/jobmanager_313, retrying in 10000 ms: Could not connect to rpc endpoint under address akka://flink/user/jobmanager_313.. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership INFO: JobManager for job 7e1e34fba0216e8b081b0b03915d25b8 with leader id b9a4be5a26d08b3addd91c23cf91496a lost leadership. Sep 20, 2018 10:02:52 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{9ddf5ba0f72cddc4ac9366fbfe05c387}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop INFO: Stopping dispatcher akka://flink/user/dispatcherc55d87f1-684a-4291-8e69-5dd0cc5190ca. Sep 20, 2018 10:02:52 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{62b0549d4a85e7c6c666459ab2aedc31}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close INFO: Closing the SlotManager. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherc55d87f1-684a-4291-8e69-5dd0cc5190ca. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend INFO: Suspending the SlotManager. Sep 20, 2018 10:02:52 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{12bb0464e57148f54afdbb970a3aa5b9}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager unregisterTaskManager INFO: Unregister TaskManager 7b6f9fcd5652a2f40bb091d094e8d1dc from the SlotManager. Sep 20, 2018 10:02:52 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{7374888ad6875a4578e54cb78428b448}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{ebb6f6dc6bc31930dcc9220110f9604c}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{07ea50ed5ac83e70d5109bbc4666c120}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{46a6eaed8a00230b6640974004236cc2}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{966fb5fc9a44bd3c0a74078a9fc54224}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{9ef2ef9e75770b6422fce4abae3f294c}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{f277577e569c46df4932f71fd4adc087}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{170fadceba6608af57679786fcf948a8}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{06990f766939badbbf0f33d08c75fc4d}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{ac2e2bd763519418158555bc43f5baf7}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{c9dc3cb6d9ffe0ba84816a3a91f09650}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 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{0f88c90db37800410b1e66b279f6ae2f}, jobId: 7e1e34fba0216e8b081b0b03915d25b8). Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob INFO: Remove job 7e1e34fba0216e8b081b0b03915d25b8 from job leader monitoring. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection INFO: Close JobManager connection for job 7e1e34fba0216e8b081b0b03915d25b8. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop INFO: Stopping TaskExecutor akka://flink/user/taskmanager_312. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown INFO: Shutting down TaskExecutorLocalStateStoresManager. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown INFO: Shutting down stack trace sample coordinator. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown INFO: I/O manager removed spill file directory /tmp/flink-io-10c5fe73-b613-4437-9a17-87082a52abcf Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0 INFO: Stopped dispatcher akka://flink/user/dispatcherc55d87f1-684a-4291-8e69-5dd0cc5190ca. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown INFO: Shutting down the network environment and its components. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.taskexecutor.JobLeaderService stop INFO: Stop job leader service. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop INFO: Stopped TaskExecutor akka://flink/user/taskmanager_312. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4 INFO: Removing cache directory /tmp/flink-web-ui Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService INFO: Stopping Akka RPC service. Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.blob.AbstractBlobCache close INFO: Shutting down BLOB cache Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.blob.AbstractBlobCache close INFO: Shutting down BLOB cache Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.blob.BlobServer close INFO: Stopped BLOB server at 0.0.0.0:46839 Sep 20, 2018 10:02:52 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4 INFO: Stopped Akka RPC service. Sep 20, 2018 10:02:52 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: Execution finished in 429 msecs Sep 20, 2018 10:02:52 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: Final accumulator values: Sep 20, 2018 10:02:52 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@38809af9 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.527 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.643 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 9,5,main]) completed. Took 4 mins 13.199 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 44s 47 actionable tasks: 43 executed, 4 from cache Publishing build scan... https://gradle.com/s/3jdoq5xilbcsq Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure