Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #2191

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/2191/display/redirect>

------------------------------------------
[...truncated 67.56 MB...]
    Nov 13, 2018 12:13:52 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/1) (7661eea4ed7f245541ed39acef91d1fb) switched from CREATED to SCHEDULED.
    Nov 13, 2018 12:13:52 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/1) (5fff4fde72a3eac98017b711d5c0f53b) switched from CREATED to SCHEDULED.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool stashRequestWaitingForResourceManager
    INFO: Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{0137e075af931a2a8b0bcb5ce5b305bf}]
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService confirmLeader
    INFO: Received confirmation of leadership for leader akka://flink/user/jobmanager_237 , session=251ad528-1463-4b9a-a3bb-fd9149f515a6
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.jobmaster.JobMaster connectToResourceManager
    INFO: Connecting to ResourceManager akka://flink/user/resourcemanager_e140dfe4-2cfd-482d-a8ac-5be2e06dd080(9e7b473e972513fafa6023502f044c35)
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0
    INFO: Resolved ResourceManager address, beginning registration
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.registration.RetryingRegistration register
    INFO: Registration at ResourceManager attempt 1 (timeout=100ms)
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobManager
    INFO: Registering job manager a3bbfd9149f515a6251ad52814634b9a@akka://flink/user/jobmanager_237 for job 69a2726d337883ad7288f532adebfc60.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobMasterInternal
    INFO: Registered job manager a3bbfd9149f515a6251ad52814634b9a@akka://flink/user/jobmanager_237 for job 69a2726d337883ad7288f532adebfc60.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.jobmaster.JobMaster establishResourceManagerConnection
    INFO: JobManager successfully registered at ResourceManager, leader id: 9e7b473e972513fafa6023502f044c35.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool requestSlotFromResourceManager
    INFO: Requesting new slot [SlotRequestId{0137e075af931a2a8b0bcb5ce5b305bf}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.resourcemanager.ResourceManager requestSlot
    INFO: Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 69a2726d337883ad7288f532adebfc60 with allocation id AllocationID{8aaf22608b5b591717a7d29629bbd912}.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot
    INFO: Receive slot request AllocationID{8aaf22608b5b591717a7d29629bbd912} for job 69a2726d337883ad7288f532adebfc60 from resource manager with leader id 9e7b473e972513fafa6023502f044c35.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot
    INFO: Allocated slot for AllocationID{8aaf22608b5b591717a7d29629bbd912}.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.JobLeaderService addJob
    INFO: Add job 69a2726d337883ad7288f532adebfc60 for job leader monitoring.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener notifyLeaderAddress
    INFO: Try to register at job manager akka://flink/user/jobmanager_237 with leader id 251ad528-1463-4b9a-a3bb-fd9149f515a6.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0
    INFO: Resolved JobManager address, beginning registration
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.registration.RetryingRegistration register
    INFO: Registration at JobManager attempt 1 (timeout=100ms)
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener$JobManagerRegisteredRpcConnection onRegistrationSuccess
    INFO: Successful registration at job manager akka://flink/user/jobmanager_237 for job 69a2726d337883ad7288f532adebfc60.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor establishJobManagerConnection
    INFO: Establish JobManager connection for job 69a2726d337883ad7288f532adebfc60.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor offerSlotsToJobManager
    INFO: Offer reserved slots to the leader of job 69a2726d337883ad7288f532adebfc60.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable markSlotActive
    INFO: Activate slot AllocationID{8aaf22608b5b591717a7d29629bbd912}.
    Nov 13, 2018 12:13:52 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/1) (7661eea4ed7f245541ed39acef91d1fb) switched from SCHEDULED to DEPLOYING.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.executiongraph.Execution deploy
    INFO: Deploying 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/1) (attempt #0) to localhost
    Nov 13, 2018 12:13:52 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/1) (5fff4fde72a3eac98017b711d5c0f53b) switched from SCHEDULED to DEPLOYING.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.executiongraph.Execution deploy
    INFO: Deploying 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/1) (attempt #0) to localhost
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
    INFO: Received 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 (1/1).
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task 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/1) (7661eea4ed7f245541ed39acef91d1fb) switched from CREATED to DEPLOYING.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Creating FileSystem stream leak safety net 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 (1/1) (7661eea4ed7f245541ed39acef91d1fb) [DEPLOYING]
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Loading JAR files 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 (1/1) (7661eea4ed7f245541ed39acef91d1fb) [DEPLOYING].
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
    INFO: Received task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1).
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Registering task at network: 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/1) (7661eea4ed7f245541ed39acef91d1fb) [DEPLOYING].
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (5fff4fde72a3eac98017b711d5c0f53b) switched from CREATED to DEPLOYING.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Creating FileSystem stream leak safety net for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (5fff4fde72a3eac98017b711d5c0f53b) [DEPLOYING]
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Loading JAR files for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (5fff4fde72a3eac98017b711d5c0f53b) [DEPLOYING].
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Registering task at network: 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/1) (5fff4fde72a3eac98017b711d5c0f53b) [DEPLOYING].
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (5fff4fde72a3eac98017b711d5c0f53b) switched from DEPLOYING to RUNNING.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.state.StateBackendLoader fromApplicationOrConfigOrDefault
    INFO: No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
    Nov 13, 2018 12:13:52 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/1) (5fff4fde72a3eac98017b711d5c0f53b) switched from DEPLOYING to RUNNING.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task 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/1) (7661eea4ed7f245541ed39acef91d1fb) switched from DEPLOYING to RUNNING.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.state.StateBackendLoader fromApplicationOrConfigOrDefault
    INFO: No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
    Nov 13, 2018 12:13:52 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/1) (7661eea4ed7f245541ed39acef91d1fb) switched from DEPLOYING to RUNNING.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/Window.Into()/Window.Assign.out exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Pair with random key/ParMultiDo(AssignShard) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:13:52 AM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState
    INFO: No restore state for UnbounedSourceWrapper.
    Nov 13, 2018 12:13:52 AM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper open
    INFO: Unbounded Flink Source 0/1 is reading from sources: [org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter@3d195db6]
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
    INFO: Initializing heap keyed state backend with stream factory.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task 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/1) (7661eea4ed7f245541ed39acef91d1fb) switched from RUNNING to FINISHED.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for 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/1) (7661eea4ed7f245541ed39acef91d1fb).
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed 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 (1/1) (7661eea4ed7f245541ed39acef91d1fb) [FINISHED]
    Nov 13, 2018 12:13:52 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 7661eea4ed7f245541ed39acef91d1fb.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (5fff4fde72a3eac98017b711d5c0f53b) switched from RUNNING to FINISHED.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (5fff4fde72a3eac98017b711d5c0f53b).
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (5fff4fde72a3eac98017b711d5c0f53b) [FINISHED]
    Nov 13, 2018 12:13:52 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) 5fff4fde72a3eac98017b711d5c0f53b.
    Nov 13, 2018 12:13:52 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/1) (7661eea4ed7f245541ed39acef91d1fb) switched from RUNNING to FINISHED.
    Nov 13, 2018 12:13:52 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/1) (5fff4fde72a3eac98017b711d5c0f53b) switched from RUNNING to FINISHED.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
    INFO: Job metricspushertest0test-jenkins-1113001351-4550b972 (69a2726d337883ad7288f532adebfc60) switched from state RUNNING to FINISHED.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
    INFO: Stopping checkpoint coordinator for job 69a2726d337883ad7288f532adebfc60.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
    INFO: Shutting down
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState
    INFO: Job 69a2726d337883ad7288f532adebfc60 reached globally terminal state FINISHED.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
    INFO: Stopping the JobMaster for job metricspushertest0test-jenkins-1113001351-4550b972(69a2726d337883ad7288f532adebfc60).
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
    INFO: Close JobManager connection for job 69a2726d337883ad7288f532adebfc60.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
    INFO: Close ResourceManager connection 9dc9b875283bf762effdf7d3cbe7b6a5: JobManager is shutting down..
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
    INFO: Suspending SlotPool.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection
    INFO: Disconnect job manager a3bbfd9149f515a6251ad52814634b9a@akka://flink/user/jobmanager_237 for job 69a2726d337883ad7288f532adebfc60 from the resource manager.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.minicluster.MiniCluster closeAsync
    INFO: Shutting down Flink Mini Cluster
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
    INFO: Stopping SlotPool.
    Nov 13, 2018 12:13:52 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{8aaf22608b5b591717a7d29629bbd912}, jobId: 69a2726d337883ad7288f532adebfc60).
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$1
    INFO: Could not resolve JobManager address akka://flink/user/jobmanager_237, retrying in 10000 ms: Could not connect to rpc endpoint under address akka://flink/user/jobmanager_237..
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
    INFO: JobManager for job 69a2726d337883ad7288f532adebfc60 with leader id a3bbfd9149f515a6251ad52814634b9a lost leadership.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
    INFO: Remove job 69a2726d337883ad7288f532adebfc60 from job leader monitoring.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
    INFO: Stopping dispatcher akka://flink/user/dispatchere1bda79b-706d-4c12-9187-f7f19fae4906.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync
    INFO: Shutting down rest endpoint.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
    INFO: Close JobManager connection for job 69a2726d337883ad7288f532adebfc60.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners
    INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatchere1bda79b-706d-4c12-9187-f7f19fae4906.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
    INFO: Closing the SlotManager.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
    INFO: Suspending the SlotManager.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
    INFO: Stopping TaskExecutor akka://flink/user/taskmanager_236.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
    INFO: Shutting down TaskExecutorLocalStateStoresManager.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
    INFO: I/O manager removed spill file directory /tmp/flink-io-4e43386d-3c5f-4fe9-ab51-4b2fc45f8f74
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown
    INFO: Shutting down stack trace sample coordinator.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
    INFO: Shutting down the network environment and its components.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0
    INFO: Stopped dispatcher akka://flink/user/dispatchere1bda79b-706d-4c12-9187-f7f19fae4906.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
    INFO: Removing cache directory /tmp/flink-web-ui
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.JobLeaderService stop
    INFO: Stop job leader service.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
    INFO: Stopped TaskExecutor akka://flink/user/taskmanager_236.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
    INFO: Stopping Akka RPC service.
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.blob.BlobServer close
    INFO: Stopped BLOB server at 0.0.0.0:45357
    Nov 13, 2018 12:13:52 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4
    INFO: Stopped Akka RPC service.
    Nov 13, 2018 12:13:52 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: Execution finished in 319 msecs
    Nov 13, 2018 12:13:52 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: Final accumulator values:
    Nov 13, 2018 12:13:52 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@e08bc387

Gradle Test Executor 4 finished executing tests.

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

242 tests completed, 16 failed, 2 skipped
Finished generating test XML results (0.11 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.087 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 2,5,main]) completed. Took 1 mins 56.558 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.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 13m 50s
48 actionable tasks: 44 executed, 4 from cache

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

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

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #2193

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/2193/display/redirect?page=changes>


---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #2192

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/2192/display/redirect?page=changes>

Changes:

[huangry] Update worker container version to most recent release.

------------------------------------------
[...truncated 67.60 MB...]
    Nov 13, 2018 12:37:01 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/1) (a3644361058e582910f01bf3f268fa90) switched from CREATED to SCHEDULED.
    Nov 13, 2018 12:37:01 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/1) (4bdcf8ce479b7918e1ffb26064e5c57e) switched from CREATED to SCHEDULED.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool stashRequestWaitingForResourceManager
    INFO: Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{ebbd15d3c822ebb21669a097d6cb8dcd}]
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService confirmLeader
    INFO: Received confirmation of leadership for leader akka://flink/user/jobmanager_237 , session=bff6633d-ca63-4521-b98c-9ac389fa764e
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.jobmaster.JobMaster connectToResourceManager
    INFO: Connecting to ResourceManager akka://flink/user/resourcemanager_b6225048-a202-48b9-9dbd-3a4331c362f5(8a652b825d533aff109b5fec227f48f6)
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0
    INFO: Resolved ResourceManager address, beginning registration
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.registration.RetryingRegistration register
    INFO: Registration at ResourceManager attempt 1 (timeout=100ms)
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobManager
    INFO: Registering job manager b98c9ac389fa764ebff6633dca634521@akka://flink/user/jobmanager_237 for job 9c1e8c68ccb2a023393cf42aa3201479.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobMasterInternal
    INFO: Registered job manager b98c9ac389fa764ebff6633dca634521@akka://flink/user/jobmanager_237 for job 9c1e8c68ccb2a023393cf42aa3201479.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.jobmaster.JobMaster establishResourceManagerConnection
    INFO: JobManager successfully registered at ResourceManager, leader id: 8a652b825d533aff109b5fec227f48f6.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool requestSlotFromResourceManager
    INFO: Requesting new slot [SlotRequestId{ebbd15d3c822ebb21669a097d6cb8dcd}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.resourcemanager.ResourceManager requestSlot
    INFO: Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 9c1e8c68ccb2a023393cf42aa3201479 with allocation id AllocationID{11e6526b60158a7c824e4e21ca9b1f7d}.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot
    INFO: Receive slot request AllocationID{11e6526b60158a7c824e4e21ca9b1f7d} for job 9c1e8c68ccb2a023393cf42aa3201479 from resource manager with leader id 8a652b825d533aff109b5fec227f48f6.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot
    INFO: Allocated slot for AllocationID{11e6526b60158a7c824e4e21ca9b1f7d}.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.JobLeaderService addJob
    INFO: Add job 9c1e8c68ccb2a023393cf42aa3201479 for job leader monitoring.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener notifyLeaderAddress
    INFO: Try to register at job manager akka://flink/user/jobmanager_237 with leader id bff6633d-ca63-4521-b98c-9ac389fa764e.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0
    INFO: Resolved JobManager address, beginning registration
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.registration.RetryingRegistration register
    INFO: Registration at JobManager attempt 1 (timeout=100ms)
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener$JobManagerRegisteredRpcConnection onRegistrationSuccess
    INFO: Successful registration at job manager akka://flink/user/jobmanager_237 for job 9c1e8c68ccb2a023393cf42aa3201479.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.TaskExecutor establishJobManagerConnection
    INFO: Establish JobManager connection for job 9c1e8c68ccb2a023393cf42aa3201479.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.TaskExecutor offerSlotsToJobManager
    INFO: Offer reserved slots to the leader of job 9c1e8c68ccb2a023393cf42aa3201479.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable markSlotActive
    INFO: Activate slot AllocationID{11e6526b60158a7c824e4e21ca9b1f7d}.
    Nov 13, 2018 12:37:01 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/1) (a3644361058e582910f01bf3f268fa90) switched from SCHEDULED to DEPLOYING.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.executiongraph.Execution deploy
    INFO: Deploying 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/1) (attempt #0) to localhost
    Nov 13, 2018 12:37:01 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/1) (4bdcf8ce479b7918e1ffb26064e5c57e) switched from SCHEDULED to DEPLOYING.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.executiongraph.Execution deploy
    INFO: Deploying 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/1) (attempt #0) to localhost
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
    INFO: Received 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 (1/1).
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task 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/1) (a3644361058e582910f01bf3f268fa90) switched from CREATED to DEPLOYING.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Creating FileSystem stream leak safety net 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 (1/1) (a3644361058e582910f01bf3f268fa90) [DEPLOYING]
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Loading JAR files 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 (1/1) (a3644361058e582910f01bf3f268fa90) [DEPLOYING].
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
    INFO: Received task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1).
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (4bdcf8ce479b7918e1ffb26064e5c57e) switched from CREATED to DEPLOYING.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Creating FileSystem stream leak safety net for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (4bdcf8ce479b7918e1ffb26064e5c57e) [DEPLOYING]
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Loading JAR files for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (4bdcf8ce479b7918e1ffb26064e5c57e) [DEPLOYING].
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Registering task at network: 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/1) (a3644361058e582910f01bf3f268fa90) [DEPLOYING].
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Registering task at network: 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/1) (4bdcf8ce479b7918e1ffb26064e5c57e) [DEPLOYING].
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (4bdcf8ce479b7918e1ffb26064e5c57e) switched from DEPLOYING to RUNNING.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.state.StateBackendLoader fromApplicationOrConfigOrDefault
    INFO: No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
    Nov 13, 2018 12:37:01 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/1) (4bdcf8ce479b7918e1ffb26064e5c57e) switched from DEPLOYING to RUNNING.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.taskmanager.Task 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/1) (a3644361058e582910f01bf3f268fa90) switched from DEPLOYING to RUNNING.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.state.StateBackendLoader fromApplicationOrConfigOrDefault
    INFO: No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
    Nov 13, 2018 12:37:01 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/1) (a3644361058e582910f01bf3f268fa90) switched from DEPLOYING to RUNNING.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/Window.Into()/Window.Assign.out exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Pair with random key/ParMultiDo(AssignShard) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
    WARNING: The operator name GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) exceeded the 80 characters length limit and was truncated.
    Nov 13, 2018 12:37:01 AM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState
    INFO: No restore state for UnbounedSourceWrapper.
    Nov 13, 2018 12:37:01 AM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper open
    INFO: Unbounded Flink Source 0/1 is reading from sources: [org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter@1970d482]
    Nov 13, 2018 12:37:01 AM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
    INFO: Initializing heap keyed state backend with stream factory.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskmanager.Task 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/1) (a3644361058e582910f01bf3f268fa90) switched from RUNNING to FINISHED.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for 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/1) (a3644361058e582910f01bf3f268fa90).
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed 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 (1/1) (a3644361058e582910f01bf3f268fa90) [FINISHED]
    Nov 13, 2018 12:37:02 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 a3644361058e582910f01bf3f268fa90.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (4bdcf8ce479b7918e1ffb26064e5c57e) switched from RUNNING to FINISHED.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (4bdcf8ce479b7918e1ffb26064e5c57e).
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/GroupByKey -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ExpandIterable/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Values/Values/Map/ParMultiDo(Anonymous) -> GenerateSequence/Read(UnboundedCountingSource)/Read/ParMultiDo(Read) -> GenerateSequence/Read(UnboundedCountingSource)/StripIds/ParMultiDo(StripIds) -> ParDo(Counting)/ParMultiDo(Counting) (1/1) (4bdcf8ce479b7918e1ffb26064e5c57e) [FINISHED]
    Nov 13, 2018 12:37:02 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) 4bdcf8ce479b7918e1ffb26064e5c57e.
    Nov 13, 2018 12:37:02 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/1) (a3644361058e582910f01bf3f268fa90) switched from RUNNING to FINISHED.
    Nov 13, 2018 12:37:02 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/1) (4bdcf8ce479b7918e1ffb26064e5c57e) switched from RUNNING to FINISHED.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
    INFO: Job metricspushertest0test-jenkins-1113003701-80508472 (9c1e8c68ccb2a023393cf42aa3201479) switched from state RUNNING to FINISHED.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
    INFO: Stopping checkpoint coordinator for job 9c1e8c68ccb2a023393cf42aa3201479.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
    INFO: Shutting down
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState
    INFO: Job 9c1e8c68ccb2a023393cf42aa3201479 reached globally terminal state FINISHED.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
    INFO: Stopping the JobMaster for job metricspushertest0test-jenkins-1113003701-80508472(9c1e8c68ccb2a023393cf42aa3201479).
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
    INFO: Close JobManager connection for job 9c1e8c68ccb2a023393cf42aa3201479.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
    INFO: Close ResourceManager connection b8855070eeb35fdf11b2013010a94960: JobManager is shutting down..
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
    INFO: Suspending SlotPool.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.rpc.akka.AkkaRpcActor onReceive
    INFO: The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet. Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is started.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection
    INFO: Disconnect job manager b98c9ac389fa764ebff6633dca634521@akka://flink/user/jobmanager_237 for job 9c1e8c68ccb2a023393cf42aa3201479 from the resource manager.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.minicluster.MiniCluster closeAsync
    INFO: Shutting down Flink Mini Cluster
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync
    INFO: Shutting down rest endpoint.
    Nov 13, 2018 12:37:02 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{11e6526b60158a7c824e4e21ca9b1f7d}, jobId: 9c1e8c68ccb2a023393cf42aa3201479).
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
    INFO: Remove job 9c1e8c68ccb2a023393cf42aa3201479 from job leader monitoring.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$1
    INFO: Could not resolve JobManager address akka://flink/user/jobmanager_237, retrying in 10000 ms: Could not connect to rpc endpoint under address akka://flink/user/jobmanager_237..
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
    INFO: Stopping SlotPool.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
    INFO: Stopping dispatcher akka://flink/user/dispatcherb4b9c59c-0bb8-4945-b8da-673571be74e1.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
    INFO: Close JobManager connection for job 9c1e8c68ccb2a023393cf42aa3201479.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners
    INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherb4b9c59c-0bb8-4945-b8da-673571be74e1.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
    INFO: Closing the SlotManager.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
    INFO: Suspending the SlotManager.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
    INFO: Stopping TaskExecutor akka://flink/user/taskmanager_236.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
    INFO: Shutting down TaskExecutorLocalStateStoresManager.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown
    INFO: Shutting down stack trace sample coordinator.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0
    INFO: Stopped dispatcher akka://flink/user/dispatcherb4b9c59c-0bb8-4945-b8da-673571be74e1.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
    INFO: I/O manager removed spill file directory /tmp/flink-io-64c2defc-9f2d-46ab-8692-db427b0a768b
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
    INFO: Shutting down the network environment and its components.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
    INFO: Removing cache directory /tmp/flink-web-ui
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskexecutor.JobLeaderService stop
    INFO: Stop job leader service.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
    INFO: Stopped TaskExecutor akka://flink/user/taskmanager_236.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
    INFO: Stopping Akka RPC service.
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.blob.BlobServer close
    INFO: Stopped BLOB server at 0.0.0.0:44567
    Nov 13, 2018 12:37:02 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4
    INFO: Stopped Akka RPC service.
    Nov 13, 2018 12:37:02 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: Execution finished in 302 msecs
    Nov 13, 2018 12:37:02 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: Final accumulator values:
    Nov 13, 2018 12:37:02 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@b1643d25

Gradle Test Executor 4 finished executing tests.

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

242 tests completed, 16 failed, 2 skipped
Finished generating test XML results (0.128 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.081 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 2,5,main]) completed. Took 2 mins 4.911 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.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 19m 48s
48 actionable tasks: 44 executed, 4 from cache

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

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

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org