See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/930/display/redirect>
------------------------------------------
[...truncated 22.88 MB...]
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (1/16)
(034c923b7ac3c0f611df7f12aed6a835) [DEPLOYING].
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (4/16) (attempt
#0) to localhost
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(8/16) (8f8d5602372d4f178852d4e6421cfa80) switched from CREATED to SCHEDULED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(1/16) (034c923b7ac3c0f611df7f12aed6a835) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(15/16) (e86a9ad7e2f49917d3f3184f13cc2ecd) switched from CREATED to SCHEDULED.
Oct 27, 2018 6:08:21 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) (8/16)
(23e52662ed7ba11bf854c37609a70107) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(7/16) (527c5a87be609caf5c4343515d0a6dcf) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(8/16) (8f8d5602372d4f178852d4e6421cfa80) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (7/16)
(527c5a87be609caf5c4343515d0a6dcf).
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(1/16) (034c923b7ac3c0f611df7f12aed6a835) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(15/16) (e86a9ad7e2f49917d3f3184f13cc2ecd) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (4/16).
Oct 27, 2018 6:08:21 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) (15/16)
(663118b6fb380d9674a848ab80c31823) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (1/16)
(034c923b7ac3c0f611df7f12aed6a835).
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(7/16) (527c5a87be609caf5c4343515d0a6dcf) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:21 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@1eb62945) (7/16)
(527c5a87be609caf5c4343515d0a6dcf) [FINISHED]
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (8/16) (attempt
#0) to localhost
Oct 27, 2018 6:08:21 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@1eb62945)
527c5a87be609caf5c4343515d0a6dcf.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(1/16) (034c923b7ac3c0f611df7f12aed6a835) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(4/16) (a7d75cdac033e0cb86cc4cb24f79153e) switched from CREATED to DEPLOYING.
Oct 27, 2018 6:08:21 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@1eb62945) (1/16)
(034c923b7ac3c0f611df7f12aed6a835) [FINISHED]
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (15/16) (attempt
#0) to localhost
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(7/16) (527c5a87be609caf5c4343515d0a6dcf) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 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@1eb62945) (4/16)
(a7d75cdac033e0cb86cc4cb24f79153e) [DEPLOYING]
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (4/16)
(a7d75cdac033e0cb86cc4cb24f79153e) [DEPLOYING].
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (8/16).
Oct 27, 2018 6:08:21 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@1eb62945)
034c923b7ac3c0f611df7f12aed6a835.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(8/16) (8f8d5602372d4f178852d4e6421cfa80) switched from CREATED to DEPLOYING.
Oct 27, 2018 6:08:21 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@1eb62945) (8/16)
(8f8d5602372d4f178852d4e6421cfa80) [DEPLOYING]
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (8/16)
(8f8d5602372d4f178852d4e6421cfa80) [DEPLOYING].
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (4/16)
(a7d75cdac033e0cb86cc4cb24f79153e) [DEPLOYING].
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(1/16) (034c923b7ac3c0f611df7f12aed6a835) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(4/16) (a7d75cdac033e0cb86cc4cb24f79153e) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (8/16)
(8f8d5602372d4f178852d4e6421cfa80) [DEPLOYING].
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(4/16) (a7d75cdac033e0cb86cc4cb24f79153e) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(8/16) (8f8d5602372d4f178852d4e6421cfa80) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (15/16).
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(8/16) (8f8d5602372d4f178852d4e6421cfa80) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(15/16) (e86a9ad7e2f49917d3f3184f13cc2ecd) switched from CREATED to DEPLOYING.
Oct 27, 2018 6:08:21 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@1eb62945) (15/16)
(e86a9ad7e2f49917d3f3184f13cc2ecd) [DEPLOYING]
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (15/16)
(e86a9ad7e2f49917d3f3184f13cc2ecd) [DEPLOYING].
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(8/16) (8f8d5602372d4f178852d4e6421cfa80) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(4/16) (a7d75cdac033e0cb86cc4cb24f79153e) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (15/16)
(e86a9ad7e2f49917d3f3184f13cc2ecd) [DEPLOYING].
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (8/16)
(8f8d5602372d4f178852d4e6421cfa80).
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (4/16)
(a7d75cdac033e0cb86cc4cb24f79153e).
Oct 27, 2018 6:08:21 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@1eb62945) (8/16)
(8f8d5602372d4f178852d4e6421cfa80) [FINISHED]
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(15/16) (e86a9ad7e2f49917d3f3184f13cc2ecd) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:21 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@1eb62945) (4/16)
(a7d75cdac033e0cb86cc4cb24f79153e) [FINISHED]
Oct 27, 2018 6:08:21 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@1eb62945)
8f8d5602372d4f178852d4e6421cfa80.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(15/16) (e86a9ad7e2f49917d3f3184f13cc2ecd) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:21 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@1eb62945)
a7d75cdac033e0cb86cc4cb24f79153e.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(15/16) (e86a9ad7e2f49917d3f3184f13cc2ecd) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945) (15/16)
(e86a9ad7e2f49917d3f3184f13cc2ecd).
Oct 27, 2018 6:08:21 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@1eb62945) (15/16)
(e86a9ad7e2f49917d3f3184f13cc2ecd) [FINISHED]
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(8/16) (8f8d5602372d4f178852d4e6421cfa80) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 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@1eb62945)
e86a9ad7e2f49917d3f3184f13cc2ecd.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(4/16) (a7d75cdac033e0cb86cc4cb24f79153e) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@1eb62945)
(15/16) (e86a9ad7e2f49917d3f3184f13cc2ecd) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027060814-a7164732 (8a0e70870540b32c0b2714830fdfc9ef)
switched from state RUNNING to FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 8a0e70870540b32c0b2714830fdfc9ef reached globally terminal state
FINISHED.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027060814-a7164732(8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 8a0e70870540b32c0b2714830fdfc9ef.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 2ece43850471817d8395c6c42708d58b:
JobManager is shutting down..
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 6:08:21 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
bde0253388c00574bfd9989254f14798@akka://flink/user/jobmanager_25 for job
8a0e70870540b32c0b2714830fdfc9ef from the resource manager.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 6:08:21 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 8a0e70870540b32c0b2714830fdfc9ef with leader id
bde0253388c00574bfd9989254f14798 lost leadership.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcherb74621c6-8348-4a70-8e8f-f69b7ab3f1e7.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcherb74621c6-8348-4a70-8e8f-f69b7ab3f1e7.
Oct 27, 2018 6:08:21 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 6:08:21 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 6:08:21 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 71f7eb18d711585a67ea2e5f26262d06 from the
SlotManager.
Oct 27, 2018 6:08:21 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{a50cf55d402314a0caee4d56df2193b5}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{055d9edf496ad5ce89326b77b2f50f3d}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 6:08:21 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{35bab9adbbe4b0f1e91e65cc79bb84fc}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcherb74621c6-8348-4a70-8e8f-f69b7ab3f1e7.
Oct 27, 2018 6:08:21 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{8ddbec87c83ac2cdacbb6d07ed99d056}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{6c3e8109a826c3764013f350bfa9067e}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{65c5b6859c83ccaf92782a318fa8b9e5}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{cda90fc8e68eb54463b973093b1981ba}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{48c57422bbd78e5d28a020a85ec68efa}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{5ccf634d3636f74f7590010128575976}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{9a475428e82b8b6140b918390984df27}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{bdf043dddb1c48d1c3b7f47eafc3f4a0}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{c9a0e78760fa77f7ebcefa81dd3833ed}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{3bfb05b3deae9e5ee3e5b43ad036a4fd}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{ae8534a5faf6a7052de929898f90f0f7}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{9c9b53eb598bbd888aa048335744bb52}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 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{7cb19c5d228609ee1728412aa978d95c}, jobId:
8a0e70870540b32c0b2714830fdfc9ef).
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 8a0e70870540b32c0b2714830fdfc9ef from job leader monitoring.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 8a0e70870540b32c0b2714830fdfc9ef.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 6:08:21 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-e11c28b8-baaa-4249-ab17-34e7d575b23b
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:35537
Oct 27, 2018 6:08:21 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 6:08:21 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5590 msecs
Oct 27, 2018 6:08:21 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 6:08:21 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@3d61f39a
2018-10-27T06:08:21.078Z Waiting for main pipeline to 'finish'
2018-10-27T06:08:21.078Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 3,5,main])
completed. Took 1 mins 25.576 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 14s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/k5u4rwdimghpu
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]
