See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/916/display/redirect>
------------------------------------------
[...truncated 22.88 MB...]
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16).
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(8/16) (aa55f343e30b64880ed1addaa3f92d41) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16)
(aa55f343e30b64880ed1addaa3f92d41).
Oct 26, 2018 6:08:37 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)
(aa55f343e30b64880ed1addaa3f92d41) [FINISHED]
Oct 26, 2018 6:08:37 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)
(225a22457033334f05e5102419d5947b) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 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)
aa55f343e30b64880ed1addaa3f92d41.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (eff50bdd2df43e2276293bea8a9dcbb3) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:08:37 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)
(eff50bdd2df43e2276293bea8a9dcbb3) [DEPLOYING]
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(8/16) (aa55f343e30b64880ed1addaa3f92d41) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:08:37 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)
(eff50bdd2df43e2276293bea8a9dcbb3) [DEPLOYING].
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(eff50bdd2df43e2276293bea8a9dcbb3) [DEPLOYING].
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(8/16) (aa55f343e30b64880ed1addaa3f92d41) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (eff50bdd2df43e2276293bea8a9dcbb3) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (eff50bdd2df43e2276293bea8a9dcbb3) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (eff50bdd2df43e2276293bea8a9dcbb3) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 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) (9/16)
(304fe1c716d5af0b367ebc96c78d568e) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 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) (9/16)
(304fe1c716d5af0b367ebc96c78d568e).
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(9/16) (3c5ff07f26d7a3a9f23348fc0f8d1d37) switched from CREATED to SCHEDULED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(eff50bdd2df43e2276293bea8a9dcbb3).
Oct 26, 2018 6:08:37 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) (9/16)
(304fe1c716d5af0b367ebc96c78d568e) [FINISHED]
Oct 26, 2018 6:08:37 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)
(eff50bdd2df43e2276293bea8a9dcbb3) [FINISHED]
Oct 26, 2018 6:08:37 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) (13/16)
(4ba4348064098c102f2adb878f1a7c57) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 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) 304fe1c716d5af0b367ebc96c78d568e.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(13/16) (7cb2652f1952376e1140e3abc2a7f23d) switched from CREATED to SCHEDULED.
Oct 26, 2018 6:08:37 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) (13/16)
(4ba4348064098c102f2adb878f1a7c57).
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(9/16) (3c5ff07f26d7a3a9f23348fc0f8d1d37) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 6:08:37 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) (13/16)
(4ba4348064098c102f2adb878f1a7c57) [FINISHED]
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16) (attempt
#0) to localhost
Oct 26, 2018 6:08:37 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)
eff50bdd2df43e2276293bea8a9dcbb3.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(13/16) (7cb2652f1952376e1140e3abc2a7f23d) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 6:08:37 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) 4ba4348064098c102f2adb878f1a7c57.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (13/16) (attempt
#0) to localhost
Oct 26, 2018 6:08:37 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) (9/16)
(304fe1c716d5af0b367ebc96c78d568e) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (eff50bdd2df43e2276293bea8a9dcbb3) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16).
Oct 26, 2018 6:08:37 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) (13/16)
(4ba4348064098c102f2adb878f1a7c57) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(9/16) (3c5ff07f26d7a3a9f23348fc0f8d1d37) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:08:37 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) (9/16)
(3c5ff07f26d7a3a9f23348fc0f8d1d37) [DEPLOYING]
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16)
(3c5ff07f26d7a3a9f23348fc0f8d1d37) [DEPLOYING].
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (13/16).
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(13/16) (7cb2652f1952376e1140e3abc2a7f23d) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:08:37 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) (13/16)
(7cb2652f1952376e1140e3abc2a7f23d) [DEPLOYING]
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (13/16)
(7cb2652f1952376e1140e3abc2a7f23d) [DEPLOYING].
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16)
(3c5ff07f26d7a3a9f23348fc0f8d1d37) [DEPLOYING].
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (13/16)
(7cb2652f1952376e1140e3abc2a7f23d) [DEPLOYING].
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(9/16) (3c5ff07f26d7a3a9f23348fc0f8d1d37) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(13/16) (7cb2652f1952376e1140e3abc2a7f23d) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(9/16) (3c5ff07f26d7a3a9f23348fc0f8d1d37) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(13/16) (7cb2652f1952376e1140e3abc2a7f23d) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(9/16) (3c5ff07f26d7a3a9f23348fc0f8d1d37) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(13/16) (7cb2652f1952376e1140e3abc2a7f23d) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16)
(3c5ff07f26d7a3a9f23348fc0f8d1d37).
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (13/16)
(7cb2652f1952376e1140e3abc2a7f23d).
Oct 26, 2018 6:08:37 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) (9/16)
(3c5ff07f26d7a3a9f23348fc0f8d1d37) [FINISHED]
Oct 26, 2018 6:08:37 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) (13/16)
(7cb2652f1952376e1140e3abc2a7f23d) [FINISHED]
Oct 26, 2018 6:08:37 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)
3c5ff07f26d7a3a9f23348fc0f8d1d37.
Oct 26, 2018 6:08:37 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)
7cb2652f1952376e1140e3abc2a7f23d.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(9/16) (3c5ff07f26d7a3a9f23348fc0f8d1d37) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(13/16) (7cb2652f1952376e1140e3abc2a7f23d) switched from RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1026180831-87b6c570 (56dbbe2e2589b1c0f4c62c6c4ec07198)
switched from state RUNNING to FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 56dbbe2e2589b1c0f4c62c6c4ec07198 reached globally terminal state
FINISHED.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1026180831-87b6c570(56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 56dbbe2e2589b1c0f4c62c6c4ec07198.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection b44e05956a41628a5abbdc12d5ab2398:
JobManager is shutting down..
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 26, 2018 6:08:37 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
bc9e0a6bedadebe5d6b379fc7be74a73@akka://flink/user/jobmanager_25 for job
56dbbe2e2589b1c0f4c62c6c4ec07198 from the resource manager.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher5e42d415-80ea-4573-8df3-456608ca37b2.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher5e42d415-80ea-4573-8df3-456608ca37b2.
Oct 26, 2018 6:08:37 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 26, 2018 6:08:37 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 56dbbe2e2589b1c0f4c62c6c4ec07198 with leader id
bc9e0a6bedadebe5d6b379fc7be74a73 lost leadership.
Oct 26, 2018 6:08:37 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 26, 2018 6:08:37 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 8b9fc6f61580f0e6301de54dbc67cab3 from the
SlotManager.
Oct 26, 2018 6:08:37 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{10317b4afe35d91f9850aa3c1ff7a1ce}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{886f74d425fc72345f10234a11702554}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher5e42d415-80ea-4573-8df3-456608ca37b2.
Oct 26, 2018 6:08:37 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{de5cedd88a102945e90c2537e7d39d8f}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{6cfc6b86080c0e307100ecae5e3f77f7}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{9b42e4d545d919e8c1577cb22abce671}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{d4e739b055af28d7e662f047a2497059}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{184675e751ba83f06f6f308d5263c5b0}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{e0891122b9936cea3ffa822af378f036}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{f1156397f35a7b642f94f1c85866263e}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{a8ef65c01436e0cb94bf67f52ba3de72}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{1bb6887c239671ee75c004f7a70d1bdf}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{9185f5e1a8444261b2995007747859b9}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{95f2b08ec39826f2d3daef2fe4f06cb4}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{4bd5a78c785e523a1e569e767ff889c4}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{0f6b6b6d04e025e06ba7d7b1ea5d0937}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 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{f46448f62026edc522840de00fc79360}, jobId:
56dbbe2e2589b1c0f4c62c6c4ec07198).
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 56dbbe2e2589b1c0f4c62c6c4ec07198 from job leader monitoring.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 56dbbe2e2589b1c0f4c62c6c4ec07198.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 6:08:37 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-6262e674-cd60-4adc-814e-876a1153cb21
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:46585
Oct 26, 2018 6:08:37 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 26, 2018 6:08:37 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5808 msecs
Oct 26, 2018 6:08:37 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 26, 2018 6:08:37 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@864fa9a7
2018-10-26T18:08:37.500Z Waiting for main pipeline to 'finish'
2018-10-26T18:08:37.500Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 4,5,main])
completed. Took 1 mins 27.45 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 22s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/c2zf54dltdmz2
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
