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: [email protected]
For additional commands, e-mail: [email protected]
