See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/918/display/redirect?page=changes>
Changes:
[scott] Move production deployment documentation to the wiki
[scott] [BEAM-5815] Update precommit triage guide for new dashboard
------------------------------------------
[...truncated 22.88 MB...]
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(6/16) (980cbb23e7d343807c8df9c997bac338) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(3/16) (2a936a057856f1e6f689694a1c4e846b) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:34:49 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@3aef037d) (6/16)
(980cbb23e7d343807c8df9c997bac338) [DEPLOYING]
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (6/16)
(980cbb23e7d343807c8df9c997bac338) [DEPLOYING].
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(5/16) (5806fd020423d794e6e4d7fe9ed176cd) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (6/16)
(980cbb23e7d343807c8df9c997bac338) [DEPLOYING].
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(3/16) (2a936a057856f1e6f689694a1c4e846b) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(3/16) (2a936a057856f1e6f689694a1c4e846b) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (3/16)
(2a936a057856f1e6f689694a1c4e846b).
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(6/16) (980cbb23e7d343807c8df9c997bac338) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:34:49 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@3aef037d) (3/16)
(2a936a057856f1e6f689694a1c4e846b) [FINISHED]
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(6/16) (980cbb23e7d343807c8df9c997bac338) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:34:49 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@3aef037d)
2a936a057856f1e6f689694a1c4e846b.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(6/16) (980cbb23e7d343807c8df9c997bac338) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (6/16)
(980cbb23e7d343807c8df9c997bac338).
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(3/16) (2a936a057856f1e6f689694a1c4e846b) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 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@3aef037d) (6/16)
(980cbb23e7d343807c8df9c997bac338) [FINISHED]
Oct 26, 2018 6:34:49 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@3aef037d)
980cbb23e7d343807c8df9c997bac338.
Oct 26, 2018 6:34:49 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) (10/16)
(2f9c294e285b56b9ee3d76410b0b8280) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 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) (10/16)
(2f9c294e285b56b9ee3d76410b0b8280).
Oct 26, 2018 6:34:49 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) (10/16)
(2f9c294e285b56b9ee3d76410b0b8280) [FINISHED]
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(6/16) (980cbb23e7d343807c8df9c997bac338) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 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) 2f9c294e285b56b9ee3d76410b0b8280.
Oct 26, 2018 6:34:49 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) (8/16)
(7b172348ad8f8f3c82d4f5cfaea0b5fe) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(10/16) (210ab1aebf4d5d6fbd129a2df265199b) switched from CREATED to SCHEDULED.
Oct 26, 2018 6:34:49 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) (8/16)
(7b172348ad8f8f3c82d4f5cfaea0b5fe).
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(8/16) (4449301d9b61cedd55400ebf2b504a2d) switched from CREATED to SCHEDULED.
Oct 26, 2018 6:34:49 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) (8/16)
(7b172348ad8f8f3c82d4f5cfaea0b5fe) [FINISHED]
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(10/16) (210ab1aebf4d5d6fbd129a2df265199b) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 6:34:49 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) 7b172348ad8f8f3c82d4f5cfaea0b5fe.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (10/16) (attempt
#0) to localhost
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(8/16) (4449301d9b61cedd55400ebf2b504a2d) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (8/16) (attempt
#0) to localhost
Oct 26, 2018 6:34:49 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) (10/16)
(2f9c294e285b56b9ee3d76410b0b8280) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (10/16).
Oct 26, 2018 6:34:49 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)
(7b172348ad8f8f3c82d4f5cfaea0b5fe) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(10/16) (210ab1aebf4d5d6fbd129a2df265199b) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:34:49 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@3aef037d) (10/16)
(210ab1aebf4d5d6fbd129a2df265199b) [DEPLOYING]
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (10/16)
(210ab1aebf4d5d6fbd129a2df265199b) [DEPLOYING].
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (8/16).
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(8/16) (4449301d9b61cedd55400ebf2b504a2d) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (10/16)
(210ab1aebf4d5d6fbd129a2df265199b) [DEPLOYING].
Oct 26, 2018 6:34:49 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@3aef037d) (8/16)
(4449301d9b61cedd55400ebf2b504a2d) [DEPLOYING]
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (8/16)
(4449301d9b61cedd55400ebf2b504a2d) [DEPLOYING].
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(10/16) (210ab1aebf4d5d6fbd129a2df265199b) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(10/16) (210ab1aebf4d5d6fbd129a2df265199b) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (8/16)
(4449301d9b61cedd55400ebf2b504a2d) [DEPLOYING].
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(8/16) (4449301d9b61cedd55400ebf2b504a2d) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(8/16) (4449301d9b61cedd55400ebf2b504a2d) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(8/16) (4449301d9b61cedd55400ebf2b504a2d) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(10/16) (210ab1aebf4d5d6fbd129a2df265199b) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (8/16)
(4449301d9b61cedd55400ebf2b504a2d).
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (10/16)
(210ab1aebf4d5d6fbd129a2df265199b).
Oct 26, 2018 6:34:49 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@3aef037d) (8/16)
(4449301d9b61cedd55400ebf2b504a2d) [FINISHED]
Oct 26, 2018 6:34:49 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@3aef037d) (10/16)
(210ab1aebf4d5d6fbd129a2df265199b) [FINISHED]
Oct 26, 2018 6:34:49 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@3aef037d)
4449301d9b61cedd55400ebf2b504a2d.
Oct 26, 2018 6:34:49 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@3aef037d)
210ab1aebf4d5d6fbd129a2df265199b.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(8/16) (4449301d9b61cedd55400ebf2b504a2d) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(10/16) (210ab1aebf4d5d6fbd129a2df265199b) switched from RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1026183442-c1bfdce (7df23425435de4138dec4e67bc5b85da)
switched from state RUNNING to FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 7df23425435de4138dec4e67bc5b85da reached globally terminal state
FINISHED.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1026183442-c1bfdce(7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 7df23425435de4138dec4e67bc5b85da.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 1239e49cd71c6d66cfd4d6e8dd9ae014:
JobManager is shutting down..
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 26, 2018 6:34:49 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
b522d69635dec682089256f4a1d440fd@akka://flink/user/jobmanager_25 for job
7df23425435de4138dec4e67bc5b85da from the resource manager.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatchereb23fa74-e2bc-4803-bc12-ecf83a28e054.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatchereb23fa74-e2bc-4803-bc12-ecf83a28e054.
Oct 26, 2018 6:34:49 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 26, 2018 6:34:49 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 7df23425435de4138dec4e67bc5b85da with leader id
b522d69635dec682089256f4a1d440fd lost leadership.
Oct 26, 2018 6:34:49 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 26, 2018 6:34:49 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 15fb76d1ce9b3a09feb097dd53532a00 from the
SlotManager.
Oct 26, 2018 6:34:49 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{fda74e8a7c2392d4357bc909920e6e5e}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{e06f7f72b868d6a3c4c7e111b3e49cb2}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{731a1cf7cda1d5fdf599c3438215c92b}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{f641cf0645c96d58dc7fab9da9a6f8d4}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{eb79e5f8ef39fd71989283f7d60849ee}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{298c254cf55771192cfbe7328fac7206}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{871818ac0690e8ab1b2d37b123a44016}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{8ff73e3cc9f9ec6638732d6fb9433f37}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{e9eb113d6bc793de28f68cba8dc0f1dd}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{fa8941a354af70c26de5a9fa3c98a06c}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{0e344def4f15b325115e27972189166e}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{09283f13af40864a737a2b7040b12882}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{5995d21ae2dc998804376ca122295d83}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{87260a9aa5c1d5e7bd79718da084b4fd}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{40c8c9a54de1919a2d0074842b6f5c8c}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 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{d298cb9bcd994ebb4868500797ec04c9}, jobId:
7df23425435de4138dec4e67bc5b85da).
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 7df23425435de4138dec4e67bc5b85da from job leader monitoring.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 7df23425435de4138dec4e67bc5b85da.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 6:34:49 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-6bf6d889-ae29-4d2d-9a0d-d952a5074d44
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 26, 2018 6:34:49 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatchereb23fa74-e2bc-4803-bc12-ecf83a28e054.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:38893
Oct 26, 2018 6:34:49 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 26, 2018 6:34:49 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 6094 msecs
Oct 26, 2018 6:34:49 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 26, 2018 6:34:49 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@89352230
2018-10-26T18:34:49.135Z Waiting for main pipeline to 'finish'
2018-10-26T18:34:49.135Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 7,5,main])
completed. Took 1 mins 27.801 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 21s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/zd7hjp3fc6qzo
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]
