You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/11/14 00:14:33 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #2211
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/2211/display/redirect>
------------------------------------------
[...truncated 55.65 MB...]
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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) switched from CREATED to SCHEDULED.
Nov 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) switched from CREATED to SCHEDULED.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool stashRequestWaitingForResourceManager
INFO: Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{fe8e094959c27effb4b2681af8291130}]
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService confirmLeader
INFO: Received confirmation of leadership for leader akka://flink/user/jobmanager_269 , session=9be02259-ea8c-4c54-9e00-c05f7fb128c9
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.jobmaster.JobMaster connectToResourceManager
INFO: Connecting to ResourceManager akka://flink/user/resourcemanager_78aa30b0-3219-4936-9017-eef44d6ed351(8d4993c10de9722b356f3cbad177415b)
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0
INFO: Resolved ResourceManager address, beginning registration
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.registration.RetryingRegistration register
INFO: Registration at ResourceManager attempt 1 (timeout=100ms)
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobManager
INFO: Registering job manager 9e00c05f7fb128c99be02259ea8c4c54@akka://flink/user/jobmanager_269 for job 77f0f16e5bce0bd41e123f6352fa011c.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobMasterInternal
INFO: Registered job manager 9e00c05f7fb128c99be02259ea8c4c54@akka://flink/user/jobmanager_269 for job 77f0f16e5bce0bd41e123f6352fa011c.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.jobmaster.JobMaster establishResourceManagerConnection
INFO: JobManager successfully registered at ResourceManager, leader id: 8d4993c10de9722b356f3cbad177415b.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool requestSlotFromResourceManager
INFO: Requesting new slot [SlotRequestId{fe8e094959c27effb4b2681af8291130}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
Nov 14, 2018 12:14:08 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 77f0f16e5bce0bd41e123f6352fa011c with allocation id AllocationID{cf1fd3a353922ad6e7a979f049d7de06}.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot
INFO: Receive slot request AllocationID{cf1fd3a353922ad6e7a979f049d7de06} for job 77f0f16e5bce0bd41e123f6352fa011c from resource manager with leader id 8d4993c10de9722b356f3cbad177415b.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot
INFO: Allocated slot for AllocationID{cf1fd3a353922ad6e7a979f049d7de06}.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.JobLeaderService addJob
INFO: Add job 77f0f16e5bce0bd41e123f6352fa011c for job leader monitoring.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener notifyLeaderAddress
INFO: Try to register at job manager akka://flink/user/jobmanager_269 with leader id 9be02259-ea8c-4c54-9e00-c05f7fb128c9.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0
INFO: Resolved JobManager address, beginning registration
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.registration.RetryingRegistration register
INFO: Registration at JobManager attempt 1 (timeout=100ms)
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener$JobManagerRegisteredRpcConnection onRegistrationSuccess
INFO: Successful registration at job manager akka://flink/user/jobmanager_269 for job 77f0f16e5bce0bd41e123f6352fa011c.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.TaskExecutor establishJobManagerConnection
INFO: Establish JobManager connection for job 77f0f16e5bce0bd41e123f6352fa011c.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.TaskExecutor offerSlotsToJobManager
INFO: Offer reserved slots to the leader of job 77f0f16e5bce0bd41e123f6352fa011c.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable markSlotActive
INFO: Activate slot AllocationID{cf1fd3a353922ad6e7a979f049d7de06}.
Nov 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) switched from SCHEDULED to DEPLOYING.
Nov 14, 2018 12:14:08 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 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) switched from SCHEDULED to DEPLOYING.
Nov 14, 2018 12:14:08 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 14, 2018 12:14:08 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 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) switched from CREATED to DEPLOYING.
Nov 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) [DEPLOYING]
Nov 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) [DEPLOYING].
Nov 14, 2018 12:14:08 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 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) switched from CREATED to DEPLOYING.
Nov 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) [DEPLOYING]
Nov 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) [DEPLOYING].
Nov 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) [DEPLOYING].
Nov 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) [DEPLOYING].
Nov 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) switched from DEPLOYING to RUNNING.
Nov 14, 2018 12:14:08 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 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) switched from DEPLOYING to RUNNING.
Nov 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) switched from DEPLOYING to RUNNING.
Nov 14, 2018 12:14:08 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 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) switched from DEPLOYING to RUNNING.
Nov 14, 2018 12:14:08 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 14, 2018 12:14:08 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 14, 2018 12:14:08 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 14, 2018 12:14:08 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 14, 2018 12:14:08 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 14, 2018 12:14:08 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 14, 2018 12:14:08 AM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState
INFO: No restore state for UnbounedSourceWrapper.
Nov 14, 2018 12:14:08 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@6a7c2a03]
Nov 14, 2018 12:14:08 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 14, 2018 12:14:08 AM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Nov 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) switched from RUNNING to FINISHED.
Nov 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf).
Nov 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) [FINISHED]
Nov 14, 2018 12:14:08 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 d4dbef05fe1bb2f4fe6b83a0f06634bf.
Nov 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) switched from RUNNING to FINISHED.
Nov 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39).
Nov 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) [FINISHED]
Nov 14, 2018 12:14:08 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) b7ef9ee6aa6bb4f4e472692d79fbfb39.
Nov 14, 2018 12:14:08 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) (d4dbef05fe1bb2f4fe6b83a0f06634bf) switched from RUNNING to FINISHED.
Nov 14, 2018 12:14:08 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) (b7ef9ee6aa6bb4f4e472692d79fbfb39) switched from RUNNING to FINISHED.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job metricspushertest0test-jenkins-1114001407-17dc2f8d (77f0f16e5bce0bd41e123f6352fa011c) switched from state RUNNING to FINISHED.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job 77f0f16e5bce0bd41e123f6352fa011c.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState
INFO: Job 77f0f16e5bce0bd41e123f6352fa011c reached globally terminal state FINISHED.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job metricspushertest0test-jenkins-1114001407-17dc2f8d(77f0f16e5bce0bd41e123f6352fa011c).
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job 77f0f16e5bce0bd41e123f6352fa011c.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
INFO: Close ResourceManager connection f3c3c81916be1d090c7bc47fb631800b: JobManager is shutting down..
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
INFO: Suspending SlotPool.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.minicluster.MiniCluster closeAsync
INFO: Shutting down Flink Mini Cluster
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection
INFO: Disconnect job manager 9e00c05f7fb128c99be02259ea8c4c54@akka://flink/user/jobmanager_269 for job 77f0f16e5bce0bd41e123f6352fa011c from the resource manager.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
INFO: Stopping SlotPool.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync
INFO: Shutting down rest endpoint.
Nov 14, 2018 12:14:08 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{cf1fd3a353922ad6e7a979f049d7de06}, jobId: 77f0f16e5bce0bd41e123f6352fa011c).
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
INFO: Remove job 77f0f16e5bce0bd41e123f6352fa011c from job leader monitoring.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher akka://flink/user/dispatcher83e2b901-4080-4f1d-9d0d-3c60079d27d3.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher83e2b901-4080-4f1d-9d0d-3c60079d27d3.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job 77f0f16e5bce0bd41e123f6352fa011c.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$1
INFO: Could not resolve JobManager address akka://flink/user/jobmanager_269, retrying in 10000 ms: Could not connect to rpc endpoint under address akka://flink/user/jobmanager_269..
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_268.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown
INFO: Shutting down stack trace sample coordinator.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory /tmp/flink-io-ca365221-61ef-400e-a2fd-be9b09e295a3
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0
INFO: Stopped dispatcher akka://flink/user/dispatcher83e2b901-4080-4f1d-9d0d-3c60079d27d3.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.JobLeaderService stop
INFO: Stop job leader service.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_268.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
INFO: Removing cache directory /tmp/flink-web-ui
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:35561
Nov 14, 2018 12:14:08 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4
INFO: Stopped Akka RPC service.
Nov 14, 2018 12:14:08 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: Execution finished in 307 msecs
Nov 14, 2018 12:14:08 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: Final accumulator values:
Nov 14, 2018 12:14:08 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@dda877cb
Gradle Test Executor 3 finished executing tests.
> Task :beam-runners-flink_2.11:validatesRunnerStreaming
Finished generating test XML results (0.418 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.329 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'
Invalidating in-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin
:beam-runners-flink_2.11:validatesRunnerStreaming (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 2 mins 56.872 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 137
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 14m 10s
48 actionable tasks: 44 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/6zn4i27kuw2aq
Build cache (/home/jenkins/.gradle/caches/build-cache-1) removing files not accessed on or after Wed Nov 07 00:00:18 UTC 2018.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4398} MaxSize{4500}, CacheStats{hitCount=0, missCount=4397, loadSuccessCount=4398, loadExceptionCount=0, totalLoadTime=814246093, evictionCount=1}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=0, missCount=4949, loadSuccessCount=4950, loadExceptionCount=0, totalLoadTime=856444359, evictionCount=451}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=0, missCount=5399, loadSuccessCount=5400, loadExceptionCount=0, totalLoadTime=880654562, evictionCount=901}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=0, missCount=5849, loadSuccessCount=5850, loadExceptionCount=0, totalLoadTime=916564386, evictionCount=1351}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=0, missCount=6299, loadSuccessCount=6300, loadExceptionCount=0, totalLoadTime=944070240, evictionCount=1801}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=0, missCount=6749, loadSuccessCount=6750, loadExceptionCount=0, totalLoadTime=979799425, evictionCount=2251}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=0, missCount=7199, loadSuccessCount=7200, loadExceptionCount=0, totalLoadTime=1013452733, evictionCount=2701}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Build cache (/home/jenkins/.gradle/caches/build-cache-1) cleaned up in 10.147 secs.
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 #2212
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/2212/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org