See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/2109/display/redirect?page=changes>
Changes: [kenn] [BEAM-5961] Add test for Nexmark main; catches BEAM-5960 [kenn] [BEAM-5817] Rollforward Nexmark BoundedSideInputJoin with fixes [scott] Fix website link-checking [scott] Fix broken website links ------------------------------------------ [...truncated 60.20 MB...] Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder buildGraph INFO: Running initialization on master for job metricspushertest0test-jenkins-1105185119-8f20bddc (67c6cff0db8bae5fe9d193cadacf4f1a). Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder buildGraph INFO: Successfully ran initialization on master in 0 ms. Nov 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService updateLeader INFO: Proposing leadership to contender org.apache.flink.runtime.jobmaster.JobManagerRunner@2559bed6 @ akka://flink/user/jobmanager_313 Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.JobManagerRunner verifyJobSchedulingStatusAndStartJobManager INFO: JobManager runner for job metricspushertest0test-jenkins-1105185119-8f20bddc (67c6cff0db8bae5fe9d193cadacf4f1a) was granted leadership with session id 3ede55d8-3053-4e72-b001-e2156a816cd7 at akka://flink/user/jobmanager_313. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.JobMaster startJobExecution INFO: Starting execution of job metricspushertest0test-jenkins-1105185119-8f20bddc (67c6cff0db8bae5fe9d193cadacf4f1a) Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState INFO: Job metricspushertest0test-jenkins-1105185119-8f20bddc (67c6cff0db8bae5fe9d193cadacf4f1a) switched from state CREATED to RUNNING. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: Source: GenerateSequence/Read(UnboundedCountingSource)/Create/Read(CreateSource) -> GenerateSequence/Read(UnboundedCountingSource)/Split/ParMultiDo(Split) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Pair with random key/ParMultiDo(AssignShard) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/Window.Into()/Window.Assign.out -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/1) (8eea9c777088f3363c502a5a820dd6c7) switched from CREATED to SCHEDULED. Nov 05, 2018 6:51:20 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/1) (f5940e3d0294f79bb5615a5c6c863efe) switched from CREATED to SCHEDULED. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService confirmLeader INFO: Received confirmation of leadership for leader akka://flink/user/jobmanager_313 , session=3ede55d8-3053-4e72-b001-e2156a816cd7 Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.JobMaster connectToResourceManager INFO: Connecting to ResourceManager akka://flink/user/resourcemanager_5ad0346c-57bf-4c82-b065-788c261ddb44(8bc13ca273ee819a30005a248bd64431) Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool stashRequestWaitingForResourceManager INFO: Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{68bded71034744c9c652a20df272b0c3}] Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0 INFO: Resolved ResourceManager address, beginning registration Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.registration.RetryingRegistration register INFO: Registration at ResourceManager attempt 1 (timeout=100ms) Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobManager INFO: Registering job manager b001e2156a816cd73ede55d830534e72@akka://flink/user/jobmanager_313 for job 67c6cff0db8bae5fe9d193cadacf4f1a. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobMasterInternal INFO: Registered job manager b001e2156a816cd73ede55d830534e72@akka://flink/user/jobmanager_313 for job 67c6cff0db8bae5fe9d193cadacf4f1a. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.JobMaster establishResourceManagerConnection INFO: JobManager successfully registered at ResourceManager, leader id: 8bc13ca273ee819a30005a248bd64431. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool requestSlotFromResourceManager INFO: Requesting new slot [SlotRequestId{68bded71034744c9c652a20df272b0c3}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. Nov 05, 2018 6:51:20 PM 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 67c6cff0db8bae5fe9d193cadacf4f1a with allocation id AllocationID{3acc94a42be00168356fbfc3f3572acd}. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot INFO: Receive slot request AllocationID{3acc94a42be00168356fbfc3f3572acd} for job 67c6cff0db8bae5fe9d193cadacf4f1a from resource manager with leader id 8bc13ca273ee819a30005a248bd64431. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot INFO: Allocated slot for AllocationID{3acc94a42be00168356fbfc3f3572acd}. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.JobLeaderService addJob INFO: Add job 67c6cff0db8bae5fe9d193cadacf4f1a for job leader monitoring. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener notifyLeaderAddress INFO: Try to register at job manager akka://flink/user/jobmanager_313 with leader id 3ede55d8-3053-4e72-b001-e2156a816cd7. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0 INFO: Resolved JobManager address, beginning registration Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.registration.RetryingRegistration register INFO: Registration at JobManager attempt 1 (timeout=100ms) Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener$JobManagerRegisteredRpcConnection onRegistrationSuccess INFO: Successful registration at job manager akka://flink/user/jobmanager_313 for job 67c6cff0db8bae5fe9d193cadacf4f1a. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor establishJobManagerConnection INFO: Establish JobManager connection for job 67c6cff0db8bae5fe9d193cadacf4f1a. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor offerSlotsToJobManager INFO: Offer reserved slots to the leader of job 67c6cff0db8bae5fe9d193cadacf4f1a. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable markSlotActive INFO: Activate slot AllocationID{3acc94a42be00168356fbfc3f3572acd}. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: Source: GenerateSequence/Read(UnboundedCountingSource)/Create/Read(CreateSource) -> GenerateSequence/Read(UnboundedCountingSource)/Split/ParMultiDo(Split) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Pair with random key/ParMultiDo(AssignShard) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/Window.Into()/Window.Assign.out -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/1) (8eea9c777088f3363c502a5a820dd6c7) switched from SCHEDULED to DEPLOYING. Nov 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 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/1) (f5940e3d0294f79bb5615a5c6c863efe) switched from SCHEDULED to DEPLOYING. Nov 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM 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) (8eea9c777088f3363c502a5a820dd6c7) switched from CREATED to DEPLOYING. Nov 05, 2018 6:51:20 PM 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) (8eea9c777088f3363c502a5a820dd6c7) [DEPLOYING] Nov 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM 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) (8eea9c777088f3363c502a5a820dd6c7) [DEPLOYING]. Nov 05, 2018 6:51:20 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) (1/1) (f5940e3d0294f79bb5615a5c6c863efe) switched from CREATED to DEPLOYING. Nov 05, 2018 6:51:20 PM 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) (f5940e3d0294f79bb5615a5c6c863efe) [DEPLOYING] Nov 05, 2018 6:51:20 PM 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) (f5940e3d0294f79bb5615a5c6c863efe) [DEPLOYING]. Nov 05, 2018 6:51:20 PM 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) (8eea9c777088f3363c502a5a820dd6c7) [DEPLOYING]. Nov 05, 2018 6:51:20 PM 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) (f5940e3d0294f79bb5615a5c6c863efe) [DEPLOYING]. Nov 05, 2018 6:51:20 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) (1/1) (f5940e3d0294f79bb5615a5c6c863efe) switched from DEPLOYING to RUNNING. Nov 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 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/1) (f5940e3d0294f79bb5615a5c6c863efe) switched from DEPLOYING to RUNNING. Nov 05, 2018 6:51:20 PM 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) (8eea9c777088f3363c502a5a820dd6c7) switched from DEPLOYING to RUNNING. Nov 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: Source: GenerateSequence/Read(UnboundedCountingSource)/Create/Read(CreateSource) -> GenerateSequence/Read(UnboundedCountingSource)/Split/ParMultiDo(Split) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Pair with random key/ParMultiDo(AssignShard) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/Window.Into()/Window.Assign.out -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/1) (8eea9c777088f3363c502a5a820dd6c7) switched from DEPLOYING to RUNNING. Nov 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM 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 05, 2018 6:51:20 PM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState INFO: No restore state for UnbounedSourceWrapper. Nov 05, 2018 6:51:20 PM 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@140a7bda] Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init> INFO: Initializing heap keyed state backend with stream factory. Nov 05, 2018 6:51:20 PM 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) (8eea9c777088f3363c502a5a820dd6c7) switched from RUNNING to FINISHED. Nov 05, 2018 6:51:20 PM 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) (8eea9c777088f3363c502a5a820dd6c7). Nov 05, 2018 6:51:20 PM 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) (8eea9c777088f3363c502a5a820dd6c7) [FINISHED] Nov 05, 2018 6:51:20 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) (1/1) (f5940e3d0294f79bb5615a5c6c863efe) switched from RUNNING to FINISHED. Nov 05, 2018 6:51:20 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) (1/1) (f5940e3d0294f79bb5615a5c6c863efe). Nov 05, 2018 6:51:20 PM 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 8eea9c777088f3363c502a5a820dd6c7. Nov 05, 2018 6:51:20 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) (1/1) (f5940e3d0294f79bb5615a5c6c863efe) [FINISHED] Nov 05, 2018 6:51:20 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) f5940e3d0294f79bb5615a5c6c863efe. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: Source: GenerateSequence/Read(UnboundedCountingSource)/Create/Read(CreateSource) -> GenerateSequence/Read(UnboundedCountingSource)/Split/ParMultiDo(Split) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Pair with random key/ParMultiDo(AssignShard) -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/Window.Into()/Window.Assign.out -> GenerateSequence/Read(UnboundedCountingSource)/Reshuffle/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/1) (8eea9c777088f3363c502a5a820dd6c7) switched from RUNNING to FINISHED. Nov 05, 2018 6:51:20 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/1) (f5940e3d0294f79bb5615a5c6c863efe) switched from RUNNING to FINISHED. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState INFO: Job metricspushertest0test-jenkins-1105185119-8f20bddc (67c6cff0db8bae5fe9d193cadacf4f1a) switched from state RUNNING to FINISHED. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown INFO: Stopping checkpoint coordinator for job 67c6cff0db8bae5fe9d193cadacf4f1a. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown INFO: Shutting down Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState INFO: Job 67c6cff0db8bae5fe9d193cadacf4f1a reached globally terminal state FINISHED. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.JobMaster postStop INFO: Stopping the JobMaster for job metricspushertest0test-jenkins-1105185119-8f20bddc(67c6cff0db8bae5fe9d193cadacf4f1a). Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection INFO: Close ResourceManager connection b296d20a7a0c0ba85d18decbc2f72ee8: JobManager is shutting down.. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection INFO: Close JobManager connection for job 67c6cff0db8bae5fe9d193cadacf4f1a. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend INFO: Suspending SlotPool. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection INFO: Disconnect job manager b001e2156a816cd73ede55d830534e72@akka://flink/user/jobmanager_313 for job 67c6cff0db8bae5fe9d193cadacf4f1a from the resource manager. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop INFO: Stopping SlotPool. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.minicluster.MiniCluster closeAsync INFO: Shutting down Flink Mini Cluster Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership INFO: JobManager for job 67c6cff0db8bae5fe9d193cadacf4f1a with leader id b001e2156a816cd73ede55d830534e72 lost leadership. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync INFO: Shutting down rest endpoint. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop INFO: Stopping dispatcher akka://flink/user/dispatcher8ca20e73-5b74-4479-aec6-2804ce147994. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher8ca20e73-5b74-4479-aec6-2804ce147994. Nov 05, 2018 6:51:20 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{3acc94a42be00168356fbfc3f3572acd}, jobId: 67c6cff0db8bae5fe9d193cadacf4f1a). Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close INFO: Closing the SlotManager. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob INFO: Remove job 67c6cff0db8bae5fe9d193cadacf4f1a from job leader monitoring. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend INFO: Suspending the SlotManager. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection INFO: Close JobManager connection for job 67c6cff0db8bae5fe9d193cadacf4f1a. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection INFO: Close JobManager connection for job 67c6cff0db8bae5fe9d193cadacf4f1a. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown INFO: Shutting down stack trace sample coordinator. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop INFO: Stopping TaskExecutor akka://flink/user/taskmanager_312. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown INFO: Shutting down TaskExecutorLocalStateStoresManager. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0 INFO: Stopped dispatcher akka://flink/user/dispatcher8ca20e73-5b74-4479-aec6-2804ce147994. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown INFO: I/O manager removed spill file directory /tmp/flink-io-1d296354-d425-4d17-a96d-e1ecb8b9f9f2 Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown INFO: Shutting down the network environment and its components. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.JobLeaderService stop INFO: Stop job leader service. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop INFO: Stopped TaskExecutor akka://flink/user/taskmanager_312. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5 INFO: Removing cache directory /tmp/flink-web-ui Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService INFO: Stopping Akka RPC service. Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.blob.AbstractBlobCache close INFO: Shutting down BLOB cache Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.blob.AbstractBlobCache close INFO: Shutting down BLOB cache Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.blob.BlobServer close INFO: Stopped BLOB server at 0.0.0.0:33205 Nov 05, 2018 6:51:20 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4 INFO: Stopped Akka RPC service. Nov 05, 2018 6:51:20 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: Execution finished in 325 msecs Nov 05, 2018 6:51:20 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: Final accumulator values: Nov 05, 2018 6:51:20 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@abbb5ce9 Gradle Test Executor 3 finished executing tests. > Task :beam-runners-flink_2.11:validatesRunnerStreaming Finished generating test XML results (0.276 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.344 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/reports/tests/validatesRunnerStreaming> Packing task ':beam-runners-flink_2.11:validatesRunnerStreaming' :beam-runners-flink_2.11:validatesRunnerStreaming (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 3 mins 2.307 secs. FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':beam-runners-flink_2.11:validatesRunnerBatch'. > Process 'Gradle Test Executor 1' finished with non-zero exit value 1 This problem might be caused by incorrect test process configuration. Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution * 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 18m 10s 48 actionable tasks: 44 executed, 4 from cache Publishing build scan... https://gradle.com/s/oib7wv2p23vdm Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org For additional commands, e-mail: builds-h...@beam.apache.org