See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/932/display/redirect>
------------------------------------------
[...truncated 22.88 MB...]
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (7/16) (attempt
#0) to localhost
Oct 27, 2018 6:08:28 PM 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)
(f161937e6fdd6fed590aeecb9ba713ac) [FINISHED]
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16) (attempt
#0) to localhost
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (2/16)
(bfea83e41a139a9f69248ca59b5282d1) [DEPLOYING].
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (2/16)
(bfea83e41a139a9f69248ca59b5282d1) [DEPLOYING].
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (4/16)
(8f704fe360324c47a0b51e6140b18e4b) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM 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) (4/16)
(8f704fe360324c47a0b51e6140b18e4b).
Oct 27, 2018 6:08:28 PM 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)
(4ecaf744383f724df0b0ff99b64f60f9) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM 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) (4/16)
(8f704fe360324c47a0b51e6140b18e4b) [FINISHED]
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(2/16) (bfea83e41a139a9f69248ca59b5282d1) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (7/16).
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (637edcfc40a6aabceb12384bda8b8a4f) switched from CREATED to SCHEDULED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(2/16) (bfea83e41a139a9f69248ca59b5282d1) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(2/16) (bfea83e41a139a9f69248ca59b5282d1) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (2/16)
(bfea83e41a139a9f69248ca59b5282d1).
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(7/16) (b2334cf97ef8ab5aa9db79fe44eb9513) switched from CREATED to DEPLOYING.
Oct 27, 2018 6:08:28 PM 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) f161937e6fdd6fed590aeecb9ba713ac.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (2/16)
(bfea83e41a139a9f69248ca59b5282d1) [FINISHED]
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (637edcfc40a6aabceb12384bda8b8a4f) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (7/16)
(b2334cf97ef8ab5aa9db79fe44eb9513) [DEPLOYING]
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16) (attempt
#0) to localhost
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (7/16)
(b2334cf97ef8ab5aa9db79fe44eb9513) [DEPLOYING].
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16).
Oct 27, 2018 6:08:28 PM 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)
(f161937e6fdd6fed590aeecb9ba713ac) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (7/16)
(b2334cf97ef8ab5aa9db79fe44eb9513) [DEPLOYING].
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(7/16) (b2334cf97ef8ab5aa9db79fe44eb9513) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(8/16) (f007f7b6c95731ff4968ed29f5d4e3ef) switched from CREATED to DEPLOYING.
Oct 27, 2018 6:08:28 PM 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) 8f704fe360324c47a0b51e6140b18e4b.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(7/16) (b2334cf97ef8ab5aa9db79fe44eb9513) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16)
(f007f7b6c95731ff4968ed29f5d4e3ef) [DEPLOYING]
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16)
(f007f7b6c95731ff4968ed29f5d4e3ef) [DEPLOYING].
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16)
(f007f7b6c95731ff4968ed29f5d4e3ef) [DEPLOYING].
Oct 27, 2018 6:08:28 PM 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@a961a70)
bfea83e41a139a9f69248ca59b5282d1.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(7/16) (b2334cf97ef8ab5aa9db79fe44eb9513) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(8/16) (f007f7b6c95731ff4968ed29f5d4e3ef) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (7/16)
(b2334cf97ef8ab5aa9db79fe44eb9513).
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (7/16)
(b2334cf97ef8ab5aa9db79fe44eb9513) [FINISHED]
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (4/16)
(8f704fe360324c47a0b51e6140b18e4b) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(8/16) (f007f7b6c95731ff4968ed29f5d4e3ef) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16).
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16)
(f007f7b6c95731ff4968ed29f5d4e3ef).
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16)
(f007f7b6c95731ff4968ed29f5d4e3ef) [FINISHED]
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(2/16) (bfea83e41a139a9f69248ca59b5282d1) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (637edcfc40a6aabceb12384bda8b8a4f) switched from CREATED to DEPLOYING.
Oct 27, 2018 6:08:28 PM 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@a961a70)
b2334cf97ef8ab5aa9db79fe44eb9513.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(8/16) (f007f7b6c95731ff4968ed29f5d4e3ef) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(637edcfc40a6aabceb12384bda8b8a4f) [DEPLOYING]
Oct 27, 2018 6:08:28 PM 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@a961a70)
f007f7b6c95731ff4968ed29f5d4e3ef.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(637edcfc40a6aabceb12384bda8b8a4f) [DEPLOYING].
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(7/16) (b2334cf97ef8ab5aa9db79fe44eb9513) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(8/16) (f007f7b6c95731ff4968ed29f5d4e3ef) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(637edcfc40a6aabceb12384bda8b8a4f) [DEPLOYING].
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (637edcfc40a6aabceb12384bda8b8a4f) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (637edcfc40a6aabceb12384bda8b8a4f) switched from DEPLOYING to RUNNING.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (637edcfc40a6aabceb12384bda8b8a4f) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(637edcfc40a6aabceb12384bda8b8a4f).
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(637edcfc40a6aabceb12384bda8b8a4f) [FINISHED]
Oct 27, 2018 6:08:28 PM 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@a961a70)
637edcfc40a6aabceb12384bda8b8a4f.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (637edcfc40a6aabceb12384bda8b8a4f) switched from RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027180822-4cf57cfb (8b5cfaa8d30ba6f20454b20f1a27e734)
switched from state RUNNING to FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 8b5cfaa8d30ba6f20454b20f1a27e734 reached globally terminal state
FINISHED.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027180822-4cf57cfb(8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 8b5cfaa8d30ba6f20454b20f1a27e734.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection f2b24a9e5868cd894ff6f5cc2f322638:
JobManager is shutting down..
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 6:08:28 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
9a57d624ae01c204f85119aef6d647e5@akka://flink/user/jobmanager_25 for job
8b5cfaa8d30ba6f20454b20f1a27e734 from the resource manager.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 6:08:28 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 8b5cfaa8d30ba6f20454b20f1a27e734 with leader id
9a57d624ae01c204f85119aef6d647e5 lost leadership.
Oct 27, 2018 6:08:28 PM
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{14d3730a9148c06bd60bb98434d7273e}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 6:08:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 6:08:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 6e326cf18187fba723d093b063a21fa0 from the
SlotManager.
Oct 27, 2018 6:08:28 PM
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{9b10b3eeaaa2f3b7a4e849de05eec99d}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher11014d27-a6a5-4f02-bd92-7f395ea6f064.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher11014d27-a6a5-4f02-bd92-7f395ea6f064.
Oct 27, 2018 6:08:28 PM
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{2e68bc606d135a2e50c4a7c3852f08cf}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{c7cfc35237ee15e52b52df68574f3e07}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{3a1bdaf83dbf5263c818cedf21dd376b}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{6f8b1b23fd88c4f3247a1370b677f055}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{616bc29fcf8d6039fd53103c5d70fe19}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{e6d74a26baaec85bfafc2bfa7dfe9fe7}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{3f5c6242ca07bd914a67d560e72e27b9}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 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{3282fd3533988503ca54e990cda99e69}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{f12bf1f65f75994f08cdb658eeed3457}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{60e6079fa71a1db9bfef88947579f40c}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{31deb3e5a9b9c75e424a49a4dae67b81}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{f1a28e42a947de75250c7b613f2913fe}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{274ca2bdfb2cb2b86977bdff69bb3c1e}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM
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{30a44268448aeef4e297c29fa825d327}, jobId:
8b5cfaa8d30ba6f20454b20f1a27e734).
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 8b5cfaa8d30ba6f20454b20f1a27e734 from job leader monitoring.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 8b5cfaa8d30ba6f20454b20f1a27e734.
Oct 27, 2018 6:08:28 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher11014d27-a6a5-4f02-bd92-7f395ea6f064.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 6:08:28 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-78fb8a51-0447-485d-a6be-9322e440bf04
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:40853
Oct 27, 2018 6:08:28 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 6:08:28 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5865 msecs
Oct 27, 2018 6:08:28 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 6:08:28 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@864fa9a7
2018-10-27T18:08:28.612Z Waiting for main pipeline to 'finish'
2018-10-27T18:08:28.612Z 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.912 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 17s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/qhyyhrj3ioqzu
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
