See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/1544/display/redirect?page=changes>
Changes:
[mxm] [BEAM-3089] Use Flink cluster parallelism if no parallelism provided
[mxm] [flink] Revert default checkpointing mode to EXACTLY_ONCE
[mxm] [flink] Use default value for checkpoint timeout
[mxm] [flink] Set default master url to [auto]
[mxm] [BEAM-3089] Test default values of FlinkPipelineOptions
------------------------------------------
[...truncated 762.05 MB...]
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) (f7fd1e0b90a2e2d74a01da4a410127df)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) (15/16) (ec021a14e50a84d048377aa2163fa9b2).
Sep 19, 2018 5:42:37 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) (13/16) (f7fd1e0b90a2e2d74a01da4a410127df).
Sep 19, 2018 5:42:37 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) (15/16) (ec021a14e50a84d048377aa2163fa9b2)
[FINISHED]
Sep 19, 2018 5:42:37 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) (9e83949fcdac1f84a0ed71a10c781d73).
Sep 19, 2018 5:42:37 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) (13/16) (f7fd1e0b90a2e2d74a01da4a410127df)
[FINISHED]
Sep 19, 2018 5:42:37 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) (9e83949fcdac1f84a0ed71a10c781d73)
[FINISHED]
Sep 19, 2018 5:42:37 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) 1568250b833eb2d2346343f4fdb76a5e.
Sep 19, 2018 5:42:37 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) fa17907c6be70416875b227b0a5a42da.
Sep 19, 2018 5:42:37 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) (1568250b833eb2d2346343f4fdb76a5e)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) 183047efb6b00b230435ec1740c40460.
Sep 19, 2018 5:42:37 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) 9954041d43c5a610b4613606ca8b6d90.
Sep 19, 2018 5:42:37 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) (fa17907c6be70416875b227b0a5a42da)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) 899fe8a9d990fad98134a74c7e09c302.
Sep 19, 2018 5:42:37 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) (183047efb6b00b230435ec1740c40460)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) d7f71098000254d945fa6b9b4b5dd96c.
Sep 19, 2018 5:42:37 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) (9954041d43c5a610b4613606ca8b6d90)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) e4fcedbdc9ef8c175deaf5767e6ecc4b.
Sep 19, 2018 5:42:37 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) (899fe8a9d990fad98134a74c7e09c302)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) b24e7a48c39b35c04ae8fe131e2da755.
Sep 19, 2018 5:42:37 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) (d7f71098000254d945fa6b9b4b5dd96c)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) (8/16) (78a94a42b551917f711255bb2745d78b)
[FINISHED]
Sep 19, 2018 5:42:37 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) 0f1036384129d6fc3986cedd5c7324e2.
Sep 19, 2018 5:42:37 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) (4/16) (21bd6e03eb096536797ec4648f661f9d)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) (e4fcedbdc9ef8c175deaf5767e6ecc4b)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) (4/16) (21bd6e03eb096536797ec4648f661f9d).
Sep 19, 2018 5:42:37 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) (9/16) (464b03e1379e85c1937d43f671a28614)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) (4/16) (21bd6e03eb096536797ec4648f661f9d)
[FINISHED]
Sep 19, 2018 5:42:37 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) (9/16) (464b03e1379e85c1937d43f671a28614).
Sep 19, 2018 5:42:37 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) (6/16) (518c8322557afd42bb0b88c39bd618fa).
Sep 19, 2018 5:42:37 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) (464b03e1379e85c1937d43f671a28614)
[FINISHED]
Sep 19, 2018 5:42:37 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) ec021a14e50a84d048377aa2163fa9b2.
Sep 19, 2018 5:42:37 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) (6/16) (518c8322557afd42bb0b88c39bd618fa)
[FINISHED]
Sep 19, 2018 5:42:37 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) (b24e7a48c39b35c04ae8fe131e2da755)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) f7fd1e0b90a2e2d74a01da4a410127df.
Sep 19, 2018 5:42:37 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) (0f1036384129d6fc3986cedd5c7324e2)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) 9e83949fcdac1f84a0ed71a10c781d73.
Sep 19, 2018 5:42:37 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) (ec021a14e50a84d048377aa2163fa9b2)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) 78a94a42b551917f711255bb2745d78b.
Sep 19, 2018 5:42:37 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) (f7fd1e0b90a2e2d74a01da4a410127df)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) 21bd6e03eb096536797ec4648f661f9d.
Sep 19, 2018 5:42:37 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) (9e83949fcdac1f84a0ed71a10c781d73)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) 464b03e1379e85c1937d43f671a28614.
Sep 19, 2018 5:42:37 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) (78a94a42b551917f711255bb2745d78b)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) 518c8322557afd42bb0b88c39bd618fa.
Sep 19, 2018 5:42:37 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) (21bd6e03eb096536797ec4648f661f9d)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) (464b03e1379e85c1937d43f671a28614)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 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) (518c8322557afd42bb0b88c39bd618fa)
switched from RUNNING to FINISHED.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job metricspushertest0test-jenkins-0919174236-b415ec8c
(88bd334d07eac21efe58f2cd2d1877cb) switched from state RUNNING to FINISHED.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job
88bd334d07eac21efe58f2cd2d1877cb.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 88bd334d07eac21efe58f2cd2d1877cb reached globally terminal state
FINISHED.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.jobmaster.JobMaster
postStop
INFO: Stopping the JobMaster for job
metricspushertest0test-jenkins-0919174236-b415ec8c(88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 928843e40b1c39da3fae23bf99edd157:
JobManager is shutting down..
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 88bd334d07eac21efe58f2cd2d1877cb.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
a388a8e5364de14fbc573eb35f1d456c@akka://flink/user/jobmanager_313 for job
88bd334d07eac21efe58f2cd2d1877cb from the resource manager.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
INFO: Suspending SlotPool.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
INFO: Stopping SlotPool.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.dispatcher.Dispatcher
postStop
INFO: Stopping dispatcher
akka://flink/user/dispatchercc5d6116-3a55-48c1-8014-d8ef62bf1dc2.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatchercc5d6116-3a55-48c1-8014-d8ef62bf1dc2.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 88bd334d07eac21efe58f2cd2d1877cb with leader id
a388a8e5364de14fbc573eb35f1d456c lost leadership.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Sep 19, 2018 5:42:37 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{b121403102e3831212ab250282c48126}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 07ab9992d76174e72c8f908ec540053f from the
SlotManager.
Sep 19, 2018 5:42:37 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{7673c3e107dc8acb7fc90e056f5c71f9}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{2d05e0e288795e05a4a3215dc3e538a2}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{2f6b6e344a951e77533753f74b077be9}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{beee94fb7e0b7c394a677196288d37c8}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{64bdfad1c2cb311950c8294800e6f3fe}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{e794a68d8f19ec4101aa829e643ec0cf}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{720a5715849d6a6101484bacd1456127}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{809e63be0b1ff054b23e3fb80fa45ef2}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{51f6e28903fd1262413811f796837f31}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{bd6f4d34691c021a3918ae405c7c491e}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{5083cf234d735b902a8c95851421a0cd}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{0dfa6b071c1f093e8d45223e8b5ec59b}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{94956e2f79b1ea6cdc7e20b5d5e47f1d}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{ed07d66d9ea5ec6af66c55087d83415d}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 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{3ceea31c5b46e65679d38d2eff0fd342}, jobId:
88bd334d07eac21efe58f2cd2d1877cb).
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
INFO: Remove job 88bd334d07eac21efe58f2cd2d1877cb from job leader
monitoring.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 88bd334d07eac21efe58f2cd2d1877cb.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_312.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-26871b25-0324-4b43-98c9-d3e415a3bbde
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatchercc5d6116-3a55-48c1-8014-d8ef62bf1dc2.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.taskexecutor.JobLeaderService stop
INFO: Stop job leader service.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_312.
Sep 19, 2018 5:42:37 PM
org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:42147
Sep 19, 2018 5:42:37 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Sep 19, 2018 5:42:37 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 415 msecs
Sep 19, 2018 5:42:37 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Sep 19, 2018 5:42:37 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@ba942217
Gradle Test Executor 4 finished executing tests.
> Task :beam-runners-flink_2.11:validatesRunnerStreaming
242 tests completed, 2 failed, 2 skipped
Finished generating test XML results (0.662 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.609 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 7,5,main]) completed. Took 4 mins 16.617 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 37s
47 actionable tasks: 42 executed, 5 from cache
Publishing build scan...
https://gradle.com/s/473r6qxtvsa7o
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
