See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/1565/display/redirect?page=changes>
Changes:
[github] [Lint] rename variable in graphx/translate.go
------------------------------------------
[...truncated 763.75 MB...]
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) 0d1b0654f3b038895a883f215fb7089b.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (8/16) (6f52baf9979f27d4b47c53ab83891888)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) bf6b18674c26b3c70a7190f0dc60a455.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (4/16) (1bff9adab47d334a91f22eff81997eb7)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (4/16) (1bff9adab47d334a91f22eff81997eb7).
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (4/16) (1bff9adab47d334a91f22eff81997eb7)
[FINISHED]
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (2/16) (aaa5313ce9c5a7e93b7ea5e470f9243e)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) be20146f559e00804b788eb3b9e0f3ae.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (7/16) (0d1b0654f3b038895a883f215fb7089b)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) c8dcd8889d0915fe2b6a37c27d044a8b.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (14/16) (bf6b18674c26b3c70a7190f0dc60a455)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) c1ffd8373cb753856c8453120725fd85.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (9/16) (33818929f1edeacbe35df9e342900d2f)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (9/16) (33818929f1edeacbe35df9e342900d2f).
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (9/16) (33818929f1edeacbe35df9e342900d2f)
[FINISHED]
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (16/16) (be20146f559e00804b788eb3b9e0f3ae)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) 38013a94c6e3e03e6575671740935bba.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (6/16) (c8dcd8889d0915fe2b6a37c27d044a8b)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) 4c2eb9a695e6545ad3d202274ad5e064.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (5/16) (c1ffd8373cb753856c8453120725fd85)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) 8b0474e6812d32c0274cb1881fffcc23.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (10/16) (38013a94c6e3e03e6575671740935bba)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) f95551a2b54a9602069e69a9443ba443.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (1/16) (4c2eb9a695e6545ad3d202274ad5e064)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task 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 cbd5401773c4bc15d1af522e0db6f3e5.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) 1bff9adab47d334a91f22eff81997eb7.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (11/16) (8b0474e6812d32c0274cb1881fffcc23)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (15/16) (f95551a2b54a9602069e69a9443ba443)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) 33818929f1edeacbe35df9e342900d2f.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source:
GenerateSequence/Read(UnboundedCountingSource)/Create/Read(CreateSource) ->
GenerateSequence/Read(UnboundedCountingSource)/Split/ParMultiDo(Split) ->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Pair with random
key/ParMultiDo(AssignShard) ->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/Window.Into()/Window.Assign.out
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
-> ToKeyedWorkItem (1/16) (cbd5401773c4bc15d1af522e0db6f3e5) switched from
RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (4/16) (1bff9adab47d334a91f22eff81997eb7)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (9/16) (33818929f1edeacbe35df9e342900d2f)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (12/16) (5f0439f4ed9926d0af1b6dae8f82edf7)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (12/16) (5f0439f4ed9926d0af1b6dae8f82edf7).
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (12/16) (5f0439f4ed9926d0af1b6dae8f82edf7)
[FINISHED]
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) 5f0439f4ed9926d0af1b6dae8f82edf7.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (13/16) (1d88b7327beca73e04be4cd70f62955c)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (13/16) (1d88b7327beca73e04be4cd70f62955c).
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (13/16) (1d88b7327beca73e04be4cd70f62955c)
[FINISHED]
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (3/16) (d3375996520ce92fb7a61196de0f6d90)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (3/16) (d3375996520ce92fb7a61196de0f6d90).
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (3/16) (d3375996520ce92fb7a61196de0f6d90)
[FINISHED]
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) 1d88b7327beca73e04be4cd70f62955c.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (12/16) (5f0439f4ed9926d0af1b6dae8f82edf7)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) d3375996520ce92fb7a61196de0f6d90.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (13/16) (1d88b7327beca73e04be4cd70f62955c)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous)
-> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) ->
GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) ->
ParDo(Counting)/ParMultiDo(Counting) (3/16) (d3375996520ce92fb7a61196de0f6d90)
switched from RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job metricspushertest0test-jenkins-0921000838-f21bd05a
(a5f8ad4fd1b95f7aef7e85785478278e) switched from state RUNNING to FINISHED.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job
a5f8ad4fd1b95f7aef7e85785478278e.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job a5f8ad4fd1b95f7aef7e85785478278e reached globally terminal state
FINISHED.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.jobmaster.JobMaster
postStop
INFO: Stopping the JobMaster for job
metricspushertest0test-jenkins-0921000838-f21bd05a(a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job a5f8ad4fd1b95f7aef7e85785478278e.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection f5df0bef457f47e76a52d87b793bd8b5:
JobManager is shutting down..
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
INFO: Suspending SlotPool.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
b1a46c9e35cdc3fc2f0be4a56e224cb1@akka://flink/user/jobmanager_313 for job
a5f8ad4fd1b95f7aef7e85785478278e from the resource manager.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
INFO: Stopping SlotPool.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job a5f8ad4fd1b95f7aef7e85785478278e with leader id
b1a46c9e35cdc3fc2f0be4a56e224cb1 lost leadership.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{e0716c781da1a3acf828f36ef7250568}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.dispatcher.Dispatcher
postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher4e647dcd-2424-46a1-9430-50deb4d48229.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher4e647dcd-2424-46a1-9430-50deb4d48229.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager d767e30c960acfc77f92cedccaadc008 from the
SlotManager.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{bd47491dedc3719c3aa3aa3ecb99ecea}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{eb2a7cd1817403216a6c4a86825b4f0f}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{7b77ce28b55916cac4d1fbf8c721b6a4}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{85254f862620d71b983a7d0f1d54e2c0}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{d6f1feafc4f94566f9e1a6817a2c9352}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{fd59ff0860400e6868b53c795b4a43e7}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{02b6b0f468e7f1eb8490bba1703f8c92}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{c2300fa16e612f223102945a5c7dab0c}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{85cffff9171a24b81c88961f4653ee61}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{addd848b74fc93310c9e909d25b5e3ce}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{6832516e0ec61673eaa18cd552a30a55}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{9c4774c839e97a787e785513798fd39c}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{1ed89cfc3c48535d37493c2c980fff10}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{aeb9c50442258b6fdf6d9841ee32ec8c}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{9db9669a7e9c7c603bd47baf26963689}, jobId:
a5f8ad4fd1b95f7aef7e85785478278e).
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
INFO: Remove job a5f8ad4fd1b95f7aef7e85785478278e from job leader
monitoring.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job a5f8ad4fd1b95f7aef7e85785478278e.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job a5f8ad4fd1b95f7aef7e85785478278e.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_312.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-edc348da-2656-4913-8c59-b372ad8fb9d8
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher4e647dcd-2424-46a1-9430-50deb4d48229.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.taskexecutor.JobLeaderService stop
INFO: Stop job leader service.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_312.
Sep 21, 2018 12:08:38 AM
org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:35889
Sep 21, 2018 12:08:38 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Sep 21, 2018 12:08:38 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 412 msecs
Sep 21, 2018 12:08:38 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Sep 21, 2018 12:08:38 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@f568454
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.532 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.607 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 13.36 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 21m 22s
47 actionable tasks: 43 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/obb765cobvaiu
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
