See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/926/display/redirect?page=changes>
Changes:
[scott] Add an OWNERS file for .test-infra/metrics
------------------------------------------
[...truncated 22.88 MB...]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(6/16) (1db3d42e739b69de5117a73bb7936afb) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (7/16)
(5f31e4b6598f28d2b83234f0f85f129c).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(1/16) (4035fd66bb1390cc58c6d8b76b2abea0) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (7/16)
(5f31e4b6598f28d2b83234f0f85f129c) [FINISHED]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (6/16)
(682271a6d6c065b3ebf89060e63e96a4).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (6/16) (attempt
#0) to localhost
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (7/16).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (16/16)
(10ae8f50f0cdb9aaed5ace510c2d88de) [FINISHED]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (5/16)
(f44ff43e9e04686b4f767b8b14602197) [DEPLOYING].
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (6/16)
(682271a6d6c065b3ebf89060e63e96a4) [FINISHED]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(7/16) (52a2fa9dd0aad3da22dfdb9d3da7345c) switched from CREATED to DEPLOYING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (7/16)
(52a2fa9dd0aad3da22dfdb9d3da7345c) [DEPLOYING]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (7/16)
(52a2fa9dd0aad3da22dfdb9d3da7345c) [DEPLOYING].
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (16/16).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (7/16)
(52a2fa9dd0aad3da22dfdb9d3da7345c) [DEPLOYING].
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) 5f31e4b6598f28d2b83234f0f85f129c.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (5/16)
(f44ff43e9e04686b4f767b8b14602197) [DEPLOYING].
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(7/16) (52a2fa9dd0aad3da22dfdb9d3da7345c) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(16/16) (94fc6a4c6f0b878e3546c2ea9b0a5a76) switched from CREATED to DEPLOYING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(5/16) (f44ff43e9e04686b4f767b8b14602197) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (16/16)
(94fc6a4c6f0b878e3546c2ea9b0a5a76) [DEPLOYING]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(7/16) (52a2fa9dd0aad3da22dfdb9d3da7345c) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (16/16)
(94fc6a4c6f0b878e3546c2ea9b0a5a76) [DEPLOYING].
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(5/16) (f44ff43e9e04686b4f767b8b14602197) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (16/16)
(94fc6a4c6f0b878e3546c2ea9b0a5a76) [DEPLOYING].
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(16/16) (94fc6a4c6f0b878e3546c2ea9b0a5a76) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (6/16).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(5/16) (f44ff43e9e04686b4f767b8b14602197) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (5/16)
(f44ff43e9e04686b4f767b8b14602197).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(7/16) (52a2fa9dd0aad3da22dfdb9d3da7345c) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(16/16) (94fc6a4c6f0b878e3546c2ea9b0a5a76) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (5/16)
(f44ff43e9e04686b4f767b8b14602197) [FINISHED]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (7/16)
(5f31e4b6598f28d2b83234f0f85f129c) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (16/16)
(94fc6a4c6f0b878e3546c2ea9b0a5a76).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(6/16) (1db3d42e739b69de5117a73bb7936afb) switched from CREATED to DEPLOYING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(16/16) (94fc6a4c6f0b878e3546c2ea9b0a5a76) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) 10ae8f50f0cdb9aaed5ace510c2d88de.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (7/16)
(52a2fa9dd0aad3da22dfdb9d3da7345c).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (6/16)
(1db3d42e739b69de5117a73bb7936afb) [DEPLOYING]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (7/16)
(52a2fa9dd0aad3da22dfdb9d3da7345c) [FINISHED]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (16/16)
(94fc6a4c6f0b878e3546c2ea9b0a5a76) [FINISHED]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (6/16)
(1db3d42e739b69de5117a73bb7936afb) [DEPLOYING].
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) 682271a6d6c065b3ebf89060e63e96a4.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
f44ff43e9e04686b4f767b8b14602197.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (16/16)
(10ae8f50f0cdb9aaed5ace510c2d88de) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (6/16)
(1db3d42e739b69de5117a73bb7936afb) [DEPLOYING].
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
52a2fa9dd0aad3da22dfdb9d3da7345c.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(6/16) (1db3d42e739b69de5117a73bb7936afb) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
94fc6a4c6f0b878e3546c2ea9b0a5a76.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (6/16)
(682271a6d6c065b3ebf89060e63e96a4) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(5/16) (f44ff43e9e04686b4f767b8b14602197) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(6/16) (1db3d42e739b69de5117a73bb7936afb) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (6/16)
(1db3d42e739b69de5117a73bb7936afb).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(6/16) (1db3d42e739b69de5117a73bb7936afb) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7) (6/16)
(1db3d42e739b69de5117a73bb7936afb) [FINISHED]
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
1db3d42e739b69de5117a73bb7936afb.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(7/16) (52a2fa9dd0aad3da22dfdb9d3da7345c) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(16/16) (94fc6a4c6f0b878e3546c2ea9b0a5a76) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@5fdaa1f7)
(6/16) (1db3d42e739b69de5117a73bb7936afb) switched from RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027022826-81efa37e (a66639047f8f584bcf7a1c041c036e0e)
switched from state RUNNING to FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job a66639047f8f584bcf7a1c041c036e0e reached globally terminal state
FINISHED.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027022826-81efa37e(a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job a66639047f8f584bcf7a1c041c036e0e.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection ec37df0a2fdd122bf6ec86195b13642e:
JobManager is shutting down..
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
8a634c6d9c37e03d16443b1c71d34aa1@akka://flink/user/jobmanager_25 for job
a66639047f8f584bcf7a1c041c036e0e from the resource manager.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job a66639047f8f584bcf7a1c041c036e0e with leader id
8a634c6d9c37e03d16443b1c71d34aa1 lost leadership.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{247357fc364ce9c33c632e5429412e62}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager c12c9631e07bf78418dc1ac963a95a69 from the
SlotManager.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcherff236fa2-6d56-4fd9-855f-4d4a74ce5d5a.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcherff236fa2-6d56-4fd9-855f-4d4a74ce5d5a.
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{8e61aced573610ab1488b183ffa634b6}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{c6dfef5b061a63774447bd5060d7c402}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{56c51d38e8b1baf3207967f178d82852}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{c11bf8fb1c08cb64271661667e8efb89}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{a97490d96b0e354e70bd7af8f4feffb7}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{cb1a25b7fcf0d99789627ff47bcf9f2d}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{add9e825334039f5aaec95fe20de293d}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{7f5d26b526345d0cf67526521e94d50d}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{6abca1856829070505000eac62130cf3}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{4fbfe0a4b990c63fe8d5c6923f0aea31}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{9e3f2b70348a6918f0d9b9fd84a13c70}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{a5ec901af9fb85a49f4ad43d116b73c9}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{ec21b69ef018c5e74d9cf2efff95c7ec}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{fd452137be94c71d62b5273b5a5cc047}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 2:28:32 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{274d00c57d557e4deb1c3d86adec0ce2}, jobId:
a66639047f8f584bcf7a1c041c036e0e).
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcherff236fa2-6d56-4fd9-855f-4d4a74ce5d5a.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job a66639047f8f584bcf7a1c041c036e0e from job leader monitoring.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job a66639047f8f584bcf7a1c041c036e0e.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 2:28:32 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-1bd57db0-e59d-41c2-bfad-6e409f759238
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:45025
Oct 27, 2018 2:28:32 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 2:28:32 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5690 msecs
Oct 27, 2018 2:28:32 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 2:28:32 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@ac3add08
2018-10-27T02:28:32.636Z Waiting for main pipeline to 'finish'
2018-10-27T02:28:32.636Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':',5,main]) completed.
Took 1 mins 24.468 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-nexmark:run'.
> Process 'command '/usr/local/asfpackages/java/jdk1.8.0_172/bin/java''
> finished with non-zero exit value 1
* 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 4m 16s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/g72bpwrgtvtau
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org
