beam-builds mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink #2699
Date Fri, 04 Jan 2019 18:23:34 GMT
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/2699/display/redirect>

------------------------------------------
[...truncated 62.39 MB...]
    INFO: Job recovers via failover strategy: full graph restart
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder
buildGraph
    INFO: Running initialization on master for job metricspushertest0test-jenkins-0104182320-967dd0f8
(05ac0d845efa5dd4752f4e8f78a45d0e).
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder
buildGraph
    INFO: Successfully ran initialization on master in 0 ms.
    Jan 04, 2019 6:23: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)
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
updateLeader
    INFO: Proposing leadership to contender org.apache.flink.runtime.jobmaster.JobManagerRunner@13106f32
@ akka://flink/user/jobmanager_269
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.jobmaster.JobManagerRunner verifyJobSchedulingStatusAndStartJobManager
    INFO: JobManager runner for job metricspushertest0test-jenkins-0104182320-967dd0f8 (05ac0d845efa5dd4752f4e8f78a45d0e)
was granted leadership with session id 6d46ca0c-c507-40f9-bb94-0178b164f391 at akka://flink/user/jobmanager_269.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.jobmaster.JobMaster startJobExecution
    INFO: Starting execution of job metricspushertest0test-jenkins-0104182320-967dd0f8 (05ac0d845efa5dd4752f4e8f78a45d0e)
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
    INFO: Job metricspushertest0test-jenkins-0104182320-967dd0f8 (05ac0d845efa5dd4752f4e8f78a45d0e)
switched from state CREATED to RUNNING.
    Jan 04, 2019 6:23: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) (519b8fbd026fc4f4d147fc7cd5fae7a3) switched from CREATED to SCHEDULED.
    Jan 04, 2019 6:23: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) (8c08cf66cc0d4c59fed2ef2caedbe680) switched
from CREATED to SCHEDULED.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool stashRequestWaitingForResourceManager
    INFO: Cannot serve slot request, no ResourceManager connected. Adding as pending request
[SlotRequestId{92bfcba44e262f4aa6ba46a5d0d17997}]
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
confirmLeader
    INFO: Received confirmation of leadership for leader akka://flink/user/jobmanager_269
, session=6d46ca0c-c507-40f9-bb94-0178b164f391
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.jobmaster.JobMaster connectToResourceManager
    INFO: Connecting to ResourceManager akka://flink/user/resourcemanager_c090a456-3b2c-447f-9250-6974082b703c(b4e7bb3da00fe29908f5960c7ec14a27)
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0
    INFO: Resolved ResourceManager address, beginning registration
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.registration.RetryingRegistration register
    INFO: Registration at ResourceManager attempt 1 (timeout=100ms)
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobManager
    INFO: Registering job manager bb940178b164f3916d46ca0cc50740f9@akka://flink/user/jobmanager_269
for job 05ac0d845efa5dd4752f4e8f78a45d0e.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.resourcemanager.ResourceManager registerJobMasterInternal
    INFO: Registered job manager bb940178b164f3916d46ca0cc50740f9@akka://flink/user/jobmanager_269
for job 05ac0d845efa5dd4752f4e8f78a45d0e.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.jobmaster.JobMaster establishResourceManagerConnection
    INFO: JobManager successfully registered at ResourceManager, leader id: b4e7bb3da00fe29908f5960c7ec14a27.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool requestSlotFromResourceManager
    INFO: Requesting new slot [SlotRequestId{92bfcba44e262f4aa6ba46a5d0d17997}] and profile
ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0,
networkMemoryInMB=0} from resource manager.
    Jan 04, 2019 6:23: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 05ac0d845efa5dd4752f4e8f78a45d0e with allocation
id AllocationID{1bb0433f540f04f8bb8e05b6f3fc20ab}.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot
    INFO: Receive slot request AllocationID{1bb0433f540f04f8bb8e05b6f3fc20ab} for job 05ac0d845efa5dd4752f4e8f78a45d0e
from resource manager with leader id b4e7bb3da00fe29908f5960c7ec14a27.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot
    INFO: Allocated slot for AllocationID{1bb0433f540f04f8bb8e05b6f3fc20ab}.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.taskexecutor.JobLeaderService addJob
    INFO: Add job 05ac0d845efa5dd4752f4e8f78a45d0e for job leader monitoring.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener
notifyLeaderAddress
    INFO: Try to register at job manager akka://flink/user/jobmanager_269 with leader id 6d46ca0c-c507-40f9-bb94-0178b164f391.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.registration.RetryingRegistration lambda$startRegistration$0
    INFO: Resolved JobManager address, beginning registration
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.registration.RetryingRegistration register
    INFO: Registration at JobManager attempt 1 (timeout=100ms)
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener$JobManagerRegisteredRpcConnection
onRegistrationSuccess
    INFO: Successful registration at job manager akka://flink/user/jobmanager_269 for job
05ac0d845efa5dd4752f4e8f78a45d0e.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor establishJobManagerConnection
    INFO: Establish JobManager connection for job 05ac0d845efa5dd4752f4e8f78a45d0e.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.taskexecutor.TaskExecutor offerSlotsToJobManager
    INFO: Offer reserved slots to the leader of job 05ac0d845efa5dd4752f4e8f78a45d0e.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable markSlotActive
    INFO: Activate slot AllocationID{1bb0433f540f04f8bb8e05b6f3fc20ab}.
    Jan 04, 2019 6:23: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) (519b8fbd026fc4f4d147fc7cd5fae7a3) switched from SCHEDULED to
DEPLOYING.
    Jan 04, 2019 6:23: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
    Jan 04, 2019 6:23: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) (8c08cf66cc0d4c59fed2ef2caedbe680) switched
from SCHEDULED to DEPLOYING.
    Jan 04, 2019 6:23: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
    Jan 04, 2019 6:23: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).
    Jan 04, 2019 6:23: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) (519b8fbd026fc4f4d147fc7cd5fae7a3) switched from CREATED to DEPLOYING.
    Jan 04, 2019 6:23: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) (519b8fbd026fc4f4d147fc7cd5fae7a3) [DEPLOYING]
    Jan 04, 2019 6:23: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) (519b8fbd026fc4f4d147fc7cd5fae7a3) [DEPLOYING].
    Jan 04, 2019 6:23: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).
    Jan 04, 2019 6:23: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) (519b8fbd026fc4f4d147fc7cd5fae7a3) [DEPLOYING].
    Jan 04, 2019 6:23: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) (8c08cf66cc0d4c59fed2ef2caedbe680) switched
from CREATED to DEPLOYING.
    Jan 04, 2019 6:23: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) (8c08cf66cc0d4c59fed2ef2caedbe680) [DEPLOYING]
    Jan 04, 2019 6:23: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) (8c08cf66cc0d4c59fed2ef2caedbe680) [DEPLOYING].
    Jan 04, 2019 6:23: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) (8c08cf66cc0d4c59fed2ef2caedbe680) [DEPLOYING].
    Jan 04, 2019 6:23: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) (8c08cf66cc0d4c59fed2ef2caedbe680) switched
from DEPLOYING to RUNNING.
    Jan 04, 2019 6:23: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)
    Jan 04, 2019 6:23: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) (8c08cf66cc0d4c59fed2ef2caedbe680) switched
from DEPLOYING to RUNNING.
    Jan 04, 2019 6:23: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) (519b8fbd026fc4f4d147fc7cd5fae7a3) switched from DEPLOYING to
RUNNING.
    Jan 04, 2019 6:23: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)
    Jan 04, 2019 6:23: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) (519b8fbd026fc4f4d147fc7cd5fae7a3) switched from DEPLOYING to
RUNNING.
    Jan 04, 2019 6:23: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.
    Jan 04, 2019 6:23: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.
    Jan 04, 2019 6:23: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.
    Jan 04, 2019 6:23: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.
    Jan 04, 2019 6:23: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.
    Jan 04, 2019 6:23:20 PM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
    INFO: No restore state for UnbounedSourceWrapper.
    Jan 04, 2019 6:23: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.
    Jan 04, 2019 6:23: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.
    Jan 04, 2019 6:23:20 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
    INFO: Initializing heap keyed state backend with stream factory.
    Jan 04, 2019 6:23: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@33a901be]
    Jan 04, 2019 6:23:21 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) (519b8fbd026fc4f4d147fc7cd5fae7a3) switched from RUNNING to FINISHED.
    Jan 04, 2019 6:23:21 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) (519b8fbd026fc4f4d147fc7cd5fae7a3).
    Jan 04, 2019 6:23:21 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) (519b8fbd026fc4f4d147fc7cd5fae7a3) [FINISHED]
    Jan 04, 2019 6:23:21 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 519b8fbd026fc4f4d147fc7cd5fae7a3.
    Jan 04, 2019 6:23:21 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) (8c08cf66cc0d4c59fed2ef2caedbe680) switched
from RUNNING to FINISHED.
    Jan 04, 2019 6:23:21 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) (8c08cf66cc0d4c59fed2ef2caedbe680).
    Jan 04, 2019 6:23:21 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) (8c08cf66cc0d4c59fed2ef2caedbe680) [FINISHED]
    Jan 04, 2019 6:23:21 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) 8c08cf66cc0d4c59fed2ef2caedbe680.
    Jan 04, 2019 6:23:21 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) (519b8fbd026fc4f4d147fc7cd5fae7a3) switched from RUNNING to FINISHED.
    Jan 04, 2019 6:23:21 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) (8c08cf66cc0d4c59fed2ef2caedbe680) switched
from RUNNING to FINISHED.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
    INFO: Job metricspushertest0test-jenkins-0104182320-967dd0f8 (05ac0d845efa5dd4752f4e8f78a45d0e)
switched from state RUNNING to FINISHED.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
    INFO: Stopping checkpoint coordinator for job 05ac0d845efa5dd4752f4e8f78a45d0e.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore
shutdown
    INFO: Shutting down
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState
    INFO: Job 05ac0d845efa5dd4752f4e8f78a45d0e reached globally terminal state FINISHED.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
    INFO: Stopping the JobMaster for job metricspushertest0test-jenkins-0104182320-967dd0f8(05ac0d845efa5dd4752f4e8f78a45d0e).
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
    INFO: Close JobManager connection for job 05ac0d845efa5dd4752f4e8f78a45d0e.
    Jan 04, 2019 6:23:21 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{1bb0433f540f04f8bb8e05b6f3fc20ab}, jobId: 05ac0d845efa5dd4752f4e8f78a45d0e).
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.minicluster.MiniCluster closeAsync
    INFO: Shutting down Flink Mini Cluster
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
    INFO: Remove job 05ac0d845efa5dd4752f4e8f78a45d0e from job leader monitoring.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
    INFO: Close JobManager connection for job 05ac0d845efa5dd4752f4e8f78a45d0e.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
    INFO: Stopping dispatcher akka://flink/user/dispatcherf0a6ffcf-9bb4-426d-9c01-8bc8cb52c618.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync
    INFO: Shutting down rest endpoint.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners
    INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherf0a6ffcf-9bb4-426d-9c01-8bc8cb52c618.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
    INFO: Stopping TaskExecutor akka://flink/user/taskmanager_268.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager
shutdown
    INFO: Shutting down TaskExecutorLocalStateStoresManager.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
close
    INFO: Closing the SlotManager.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
suspend
    INFO: Suspending the SlotManager.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
    INFO: Suspending SlotPool.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
    INFO: Close ResourceManager connection faf4681be4c235dfd819f3a3ba20c148: JobManager is
shutting down..
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
    INFO: I/O manager removed spill file directory /tmp/flink-io-87f0156b-bc1c-485b-9ede-fc56ac3e93f0
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
    INFO: Shutting down the network environment and its components.
    Jan 04, 2019 6:23:21 PM 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.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
    INFO: Stopping SlotPool.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
    INFO: Shutting down stack trace sample coordinator.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.taskexecutor.JobLeaderService stop
    INFO: Stop job leader service.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
    INFO: Stopped TaskExecutor akka://flink/user/taskmanager_268.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0
    INFO: Stopped dispatcher akka://flink/user/dispatcherf0a6ffcf-9bb4-426d-9c01-8bc8cb52c618.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$5
    INFO: Removing cache directory /tmp/flink-web-ui
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.rest.RestServerEndpoint lambda$closeAsync$1
    INFO: Shut down complete.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
    INFO: Stopping Akka RPC service.
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.blob.BlobServer close
    INFO: Stopped BLOB server at 0.0.0.0:44159
    Jan 04, 2019 6:23:21 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4
    INFO: Stopped Akka RPC service.
    Jan 04, 2019 6:23:21 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: Execution finished in 305 msecs
    Jan 04, 2019 6:23:21 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: Final accumulator values:
    Jan 04, 2019 6:23:21 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
    INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@ea7b1f00

Gradle Test Executor 4 finished executing tests.

> Task :beam-runners-flink_2.11:validatesRunnerStreaming
Finished generating test XML results (0.225 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/ws/src/runners/flink/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.199 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/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 3,5,main])
completed. Took 2 mins 36.434 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.3/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.3/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 23m 16s
47 actionable tasks: 44 executed, 3 from cache

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

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


Mime
View raw message