beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #1549
Date Wed, 19 Sep 2018 22:03:29 GMT
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/1549/display/redirect?page=changes>

Changes:

[amaliujia] create external table

[amaliujia] change CREATE TABLE to CREATE EXTERNAL TABLE in tests.

[amaliujia] throw ParseException to remind using create external table when input

------------------------------------------
[...truncated 762.79 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) c663a677c57917de3bfe8380bb178491.
    Sep 19, 2018 10:03:16 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) (09f805d18ec78703be7ebd723ee0cb43) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) 231909e4292604bed3e7a66e94e017ed.
    Sep 19, 2018 10:03:16 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) (3b363bf07d49c34674e6d6a36d858f1f) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (797e2e6549986f87c242e7b63aebd962) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (060e4c57a07f45455528ca4cfce0153f) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (c663a677c57917de3bfe8380bb178491) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (231909e4292604bed3e7a66e94e017ed) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (14/16) (d4619962a7710d44e0036ee9b44823da) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (14/16) (d4619962a7710d44e0036ee9b44823da).
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (14/16) (d4619962a7710d44e0036ee9b44823da) [FINISHED]
    Sep 19, 2018 10:03:16 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) d4619962a7710d44e0036ee9b44823da.
    Sep 19, 2018 10:03:16 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) (d4619962a7710d44e0036ee9b44823da) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (13/16) (69b0e880761b5134dd5883abd4535ef2) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (69b0e880761b5134dd5883abd4535ef2).
    Sep 19, 2018 10:03:16 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) (69b0e880761b5134dd5883abd4535ef2) [FINISHED]
    Sep 19, 2018 10:03:16 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) 69b0e880761b5134dd5883abd4535ef2.
    Sep 19, 2018 10:03:16 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) (69b0e880761b5134dd5883abd4535ef2) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (11/16) (33fcab0eac26af0951ea0c03badc3c1e) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (11/16) (33fcab0eac26af0951ea0c03badc3c1e).
    Sep 19, 2018 10:03:16 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) (11/16) (33fcab0eac26af0951ea0c03badc3c1e) [FINISHED]
    Sep 19, 2018 10:03:16 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) (af8b3f7cc56a185ff8a14d622376cd43) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (af8b3f7cc56a185ff8a14d622376cd43).
    Sep 19, 2018 10:03:16 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) 33fcab0eac26af0951ea0c03badc3c1e.
    Sep 19, 2018 10:03:16 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) (af8b3f7cc56a185ff8a14d622376cd43) [FINISHED]
    Sep 19, 2018 10:03:16 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) af8b3f7cc56a185ff8a14d622376cd43.
    Sep 19, 2018 10:03:16 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) (33fcab0eac26af0951ea0c03badc3c1e) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (af8b3f7cc56a185ff8a14d622376cd43) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (15/16) (67f667a61f2edcc387c8ea348be182db) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (67f667a61f2edcc387c8ea348be182db).
    Sep 19, 2018 10:03:16 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) (67f667a61f2edcc387c8ea348be182db) [FINISHED]
    Sep 19, 2018 10:03:16 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) 67f667a61f2edcc387c8ea348be182db.
    Sep 19, 2018 10:03:16 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) (67f667a61f2edcc387c8ea348be182db) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (1e672058186f9cf215aeff5f59055741) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (1e672058186f9cf215aeff5f59055741).
    Sep 19, 2018 10:03:16 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) (16/16) (bb9052f6198ae91581c1fd9a5cc1f975) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (1e672058186f9cf215aeff5f59055741) [FINISHED]
    Sep 19, 2018 10:03:16 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) (16/16) (bb9052f6198ae91581c1fd9a5cc1f975).
    Sep 19, 2018 10:03:16 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) (16/16) (bb9052f6198ae91581c1fd9a5cc1f975) [FINISHED]
    Sep 19, 2018 10:03:16 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) 1e672058186f9cf215aeff5f59055741.
    Sep 19, 2018 10:03:16 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) bb9052f6198ae91581c1fd9a5cc1f975.
    Sep 19, 2018 10:03:16 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) (1e672058186f9cf215aeff5f59055741) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (bb9052f6198ae91581c1fd9a5cc1f975) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (5/16) (b9469ae740cb66334ca07b078dfe648e) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 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) (b9469ae740cb66334ca07b078dfe648e).
    Sep 19, 2018 10:03:16 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) (b9469ae740cb66334ca07b078dfe648e) [FINISHED]
    Sep 19, 2018 10:03:16 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) b9469ae740cb66334ca07b078dfe648e.
    Sep 19, 2018 10:03:16 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) (b9469ae740cb66334ca07b078dfe648e) switched from RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
    INFO: Job metricspushertest0test-jenkins-0919220315-ac3d01a9 (3df550331d07ba2d534ac3131e06f021) switched from state RUNNING to FINISHED.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
    INFO: Stopping checkpoint coordinator for job 3df550331d07ba2d534ac3131e06f021.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
    INFO: Shutting down
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState
    INFO: Job 3df550331d07ba2d534ac3131e06f021 reached globally terminal state FINISHED.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
    INFO: Stopping the JobMaster for job metricspushertest0test-jenkins-0919220315-ac3d01a9(3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
    INFO: Close JobManager connection for job 3df550331d07ba2d534ac3131e06f021.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
    INFO: Close ResourceManager connection 609ac5246293b2171bea0bddd66e2ff9: JobManager is shutting down..
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
    INFO: Suspending SlotPool.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.minicluster.MiniCluster closeAsync
    INFO: Shutting down Flink Mini Cluster
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection
    INFO: Disconnect job manager a6781aac262a2760b390e79b97a74665@akka://flink/user/jobmanager_313 for job 3df550331d07ba2d534ac3131e06f021 from the resource manager.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
    INFO: Stopping SlotPool.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
    INFO: JobManager for job 3df550331d07ba2d534ac3131e06f021 with leader id a6781aac262a2760b390e79b97a74665 lost leadership.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
    INFO: Stopping dispatcher akka://flink/user/dispatcher1f3218a9-d3ea-40de-95b2-0ff476bb47c2.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync
    INFO: Shutting down rest endpoint.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners
    INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher1f3218a9-d3ea-40de-95b2-0ff476bb47c2.
    Sep 19, 2018 10:03:16 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{1cf2fe46c04c4b3b1b06c7eccfea2578}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
    INFO: Closing the SlotManager.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
    INFO: Suspending the SlotManager.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager unregisterTaskManager
    INFO: Unregister TaskManager 929629c54a0a0263346c58125287eefb from the SlotManager.
    Sep 19, 2018 10:03:16 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{ee175d62a6b7f04949b8a0c9b8eb488c}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{5cc6d9872818a6cf021db73e2f1fa9d1}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown
    INFO: Shutting down stack trace sample coordinator.
    Sep 19, 2018 10:03:16 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{fa673e41b730aca7dd46c1e8c4f43831}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0
    INFO: Stopped dispatcher akka://flink/user/dispatcher1f3218a9-d3ea-40de-95b2-0ff476bb47c2.
    Sep 19, 2018 10:03:16 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{809ebac63035fc9adfc5b141c02c3ca0}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{0be3f3d3c46267ba76fdfd0760ae1d80}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{ed9d4a47241310866746b3988ef3f7bd}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{5da2ef889be8ca3e543d288d86bc1df4}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{164e894be7b9c7fbbe09702dc303132e}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{5eef5ef678a108b2e2562380eba5b5a2}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{fd51c8358ba3910bb9ac0f703efda26c}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{1d89746f92d01a0553af4c4db794e7c8}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{f8d713709af17654e17e859878a58347}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{c6d3d0bef968625125c784d0ce3ead7e}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{9d601cb73d78aecfb56f9372f2c6d121}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 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{1a34e1e836dab8f448ed256901c218ac}, jobId: 3df550331d07ba2d534ac3131e06f021).
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
    INFO: Remove job 3df550331d07ba2d534ac3131e06f021 from job leader monitoring.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
    INFO: Close JobManager connection for job 3df550331d07ba2d534ac3131e06f021.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
    INFO: Stopping TaskExecutor akka://flink/user/taskmanager_312.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
    INFO: Shutting down TaskExecutorLocalStateStoresManager.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
    INFO: I/O manager removed spill file directory /tmp/flink-io-1a4e0090-3a07-4273-9de0-8b2f7c21214b
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
    INFO: Shutting down the network environment and its components.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.taskexecutor.JobLeaderService stop
    INFO: Stop job leader service.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
    INFO: Stopped TaskExecutor akka://flink/user/taskmanager_312.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4
    INFO: Removing cache directory /tmp/flink-web-ui
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
    INFO: Stopping Akka RPC service.
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.blob.BlobServer close
    INFO: Stopped BLOB server at 0.0.0.0:42337
    Sep 19, 2018 10:03:16 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4
    INFO: Stopped Akka RPC service.
    Sep 19, 2018 10:03:16 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: Execution finished in 407 msecs
    Sep 19, 2018 10:03:16 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: Final accumulator values:
    Sep 19, 2018 10:03:16 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@1e342b

Gradle Test Executor 3 finished executing tests.

> Task :beam-runners-flink_2.11:validatesRunnerStreaming

242 tests completed, 2 failed, 2 skipped
Finished generating test XML results (0.591 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.66 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[Daemon worker,5,main]) completed. Took 4 mins 19.998 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 35s
47 actionable tasks: 43 executed, 4 from cache

Publishing build scan...
https://gradle.com/s/v5pwq554vklgo

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

Mime
View raw message