See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/923/display/redirect>
------------------------------------------
[...truncated 22.93 MB...]
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (2/16).
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task CHAIN MapPartition
(MapPartition at Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4) [DEPLOYING]
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4) [DEPLOYING].
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4) [DEPLOYING].
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (6/16).
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:43 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) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(6/16) (d9b59af980ef1bb5faad34ec272eb687) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:08:43 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@2fc32429) (6/16)
(d9b59af980ef1bb5faad34ec272eb687) [DEPLOYING]
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (6/16)
(d9b59af980ef1bb5faad34ec272eb687) [DEPLOYING].
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (6/16)
(d9b59af980ef1bb5faad34ec272eb687) [DEPLOYING].
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(6/16) (d9b59af980ef1bb5faad34ec272eb687) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(6/16) (d9b59af980ef1bb5faad34ec272eb687) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(6/16) (d9b59af980ef1bb5faad34ec272eb687) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (6/16)
(d9b59af980ef1bb5faad34ec272eb687).
Oct 27, 2018 12:08:43 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@2fc32429) (6/16)
(d9b59af980ef1bb5faad34ec272eb687) [FINISHED]
Oct 27, 2018 12:08:43 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@2fc32429)
d9b59af980ef1bb5faad34ec272eb687.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (3/16)
(43ba066e5da3043cd50e5a5adbb1ad57) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 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) (3/16)
(43ba066e5da3043cd50e5a5adbb1ad57).
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(6/16) (d9b59af980ef1bb5faad34ec272eb687) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 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) (3/16)
(43ba066e5da3043cd50e5a5adbb1ad57) [FINISHED]
Oct 27, 2018 12:08:43 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) 43ba066e5da3043cd50e5a5adbb1ad57.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(3/16) (a9c57c4d5fa196e7dfb70f28f4b9aeef) switched from CREATED to SCHEDULED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(3/16) (a9c57c4d5fa196e7dfb70f28f4b9aeef) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (3/16) (attempt
#0) to localhost
Oct 27, 2018 12:08:43 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) (3/16)
(43ba066e5da3043cd50e5a5adbb1ad57) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 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) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4).
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (8aeae11dcb9214d51b1deafdbb914f90) switched from CREATED to SCHEDULED.
Oct 27, 2018 12:08:43 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) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4) [FINISHED]
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (3/16).
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (8aeae11dcb9214d51b1deafdbb914f90) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 12:08:43 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) b0f17ce4878c63c34c2870ebfe3c8bb4.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(3/16) (a9c57c4d5fa196e7dfb70f28f4b9aeef) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (2/16) (attempt
#0) to localhost
Oct 27, 2018 12:08:43 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@2fc32429) (3/16)
(a9c57c4d5fa196e7dfb70f28f4b9aeef) [DEPLOYING]
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (3/16)
(a9c57c4d5fa196e7dfb70f28f4b9aeef) [DEPLOYING].
Oct 27, 2018 12:08:43 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) (2/16)
(b0f17ce4878c63c34c2870ebfe3c8bb4) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (2/16).
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (3/16)
(a9c57c4d5fa196e7dfb70f28f4b9aeef) [DEPLOYING].
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (8aeae11dcb9214d51b1deafdbb914f90) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(3/16) (a9c57c4d5fa196e7dfb70f28f4b9aeef) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:43 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@2fc32429) (2/16)
(8aeae11dcb9214d51b1deafdbb914f90) [DEPLOYING]
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (2/16)
(8aeae11dcb9214d51b1deafdbb914f90) [DEPLOYING].
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(3/16) (a9c57c4d5fa196e7dfb70f28f4b9aeef) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (2/16)
(8aeae11dcb9214d51b1deafdbb914f90) [DEPLOYING].
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (8aeae11dcb9214d51b1deafdbb914f90) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (8aeae11dcb9214d51b1deafdbb914f90) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(3/16) (a9c57c4d5fa196e7dfb70f28f4b9aeef) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (8aeae11dcb9214d51b1deafdbb914f90) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (3/16)
(a9c57c4d5fa196e7dfb70f28f4b9aeef).
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (2/16)
(8aeae11dcb9214d51b1deafdbb914f90).
Oct 27, 2018 12:08:43 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@2fc32429) (3/16)
(a9c57c4d5fa196e7dfb70f28f4b9aeef) [FINISHED]
Oct 27, 2018 12:08:43 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@2fc32429) (2/16)
(8aeae11dcb9214d51b1deafdbb914f90) [FINISHED]
Oct 27, 2018 12:08:43 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@2fc32429)
a9c57c4d5fa196e7dfb70f28f4b9aeef.
Oct 27, 2018 12:08:43 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@2fc32429)
8aeae11dcb9214d51b1deafdbb914f90.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(3/16) (a9c57c4d5fa196e7dfb70f28f4b9aeef) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (8aeae11dcb9214d51b1deafdbb914f90) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027000836-d254f563 (12016408638657c913e203ac1bfbca5a)
switched from state RUNNING to FINISHED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 12016408638657c913e203ac1bfbca5a reached globally terminal state
FINISHED.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027000836-d254f563(12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 12016408638657c913e203ac1bfbca5a.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 5809dd2f6618a44de9e543cb5bca283e:
JobManager is shutting down..
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 12:08:43 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
a98548b6f981f0d98b341d60a82d4f69@akka://flink/user/jobmanager_25 for job
12016408638657c913e203ac1bfbca5a from the resource manager.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcherf4ea2b88-9bce-4117-8cf2-16edf8c07e4f.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcherf4ea2b88-9bce-4117-8cf2-16edf8c07e4f.
Oct 27, 2018 12:08:43 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 12016408638657c913e203ac1bfbca5a with leader id
a98548b6f981f0d98b341d60a82d4f69 lost leadership.
Oct 27, 2018 12:08:43 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 12:08:43 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 12:08:43 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager f65f1161d6303519999c68a904ad0540 from the
SlotManager.
Oct 27, 2018 12:08:43 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{610d51c7d1ce45904b2c23b11725c85f}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{c69c570efd6b30a91e7c9070b36506e2}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{b6819307c949c4ca4316ad6e74f0ad14}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{74e8c2e2ef577fc817c57ef4309d4d2c}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{65124762d291e6fa4f0ec0459e638cfa}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{5331a9acb435b26f1f28cc3851b14446}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{33f5f36179a85bc677abfcf99d35a59d}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{7002231a0c15451a415460f98a718038}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{4463d7dc027ebdd92bc9729c27fe2f20}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{2f11772ec79273eb725ace585d0f92dc}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{35bcbe1dddb224229d6dc82f33fd78e3}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{33cb4b48060bc1191d4fd0c43f11c437}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{89a596472a024b05842d2060c16c00ba}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{17739dd96cdaf9577eb1e7f77098ac24}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{72a762e241bee2cadc8a22f4b4078d41}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 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{f235105a50d5ed39a5d37a6fc147e2fd}, jobId:
12016408638657c913e203ac1bfbca5a).
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 12016408638657c913e203ac1bfbca5a from job leader monitoring.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 12016408638657c913e203ac1bfbca5a.
Oct 27, 2018 12:08:43 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcherf4ea2b88-9bce-4117-8cf2-16edf8c07e4f.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 12:08:43 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-8263450a-af6d-43ad-b9da-d1a40e9b9089
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:38307
Oct 27, 2018 12:08:43 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 12:08:43 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 6199 msecs
Oct 27, 2018 12:08:43 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 12:08:43 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@68ae5f5a
2018-10-27T00:08:43.476Z Waiting for main pipeline to 'finish'
2018-10-27T00:08:43.476Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 2,5,main])
completed. Took 1 mins 29.189 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 28s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/mdkiopnapics4
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
