See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/925/display/redirect?page=changes>
Changes:
[ccy] Revert "Merge pull request #6837 [BEAM-5853] Fix in
[ccy] Revert "Merge pull request #6807: [BEAM-5833] Fix java-harness build by
[ccy] Revert "Merge pull request #6798: [BEAM-5833] Fix checkstyle breakage"
[ccy] Revert "Merge pull request #6752 [BEAM-5791] Dataflow harness data plane
------------------------------------------
[...truncated 22.88 MB...]
Oct 27, 2018 2:03:44 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@3aef037d) (12/16)
(9dd907cea3f632bd00de50db42cd130c) [FINISHED]
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (1/16)
(0fcc0b495e8f8c0c6e26cf2cb476ca98) [DEPLOYING].
Oct 27, 2018 2:03:44 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) (4/16)
(5f8dcc0e12f7aceab27b9f9a8b19aa86) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 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) (4/16)
(5f8dcc0e12f7aceab27b9f9a8b19aa86).
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (0fcc0b495e8f8c0c6e26cf2cb476ca98) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:03:44 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) (4/16)
(5f8dcc0e12f7aceab27b9f9a8b19aa86) [FINISHED]
Oct 27, 2018 2:03:44 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) (5/16).
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at Query12.Format/ParMultiDo(Anonymous))
-> FlatMap (FlatMap at Query12.Format/ParMultiDo(Anonymous).output) (5/16)
(61014bfb8831a15c05e323a3478b51d8) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (0fcc0b495e8f8c0c6e26cf2cb476ca98) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (1/16)
(0fcc0b495e8f8c0c6e26cf2cb476ca98).
Oct 27, 2018 2:03:44 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@3aef037d)
9dd907cea3f632bd00de50db42cd130c.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(4/16) (097d4214f9ed8e2b03ec133058ca3797) switched from CREATED to SCHEDULED.
Oct 27, 2018 2:03:44 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@3aef037d) (1/16)
(0fcc0b495e8f8c0c6e26cf2cb476ca98) [FINISHED]
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (0fcc0b495e8f8c0c6e26cf2cb476ca98) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d) switched from CREATED to DEPLOYING.
Oct 27, 2018 2:03:44 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) 5f8dcc0e12f7aceab27b9f9a8b19aa86.
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d) [DEPLOYING]
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(4/16) (097d4214f9ed8e2b03ec133058ca3797) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(12/16) (9dd907cea3f632bd00de50db42cd130c) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (4/16) (attempt
#0) to localhost
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d) [DEPLOYING].
Oct 27, 2018 2:03:44 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@3aef037d)
0fcc0b495e8f8c0c6e26cf2cb476ca98.
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d) [DEPLOYING].
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (4/16).
Oct 27, 2018 2:03:44 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) (4/16)
(5f8dcc0e12f7aceab27b9f9a8b19aa86) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(4/16) (097d4214f9ed8e2b03ec133058ca3797) switched from CREATED to DEPLOYING.
Oct 27, 2018 2:03:44 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@3aef037d) (4/16)
(097d4214f9ed8e2b03ec133058ca3797) [DEPLOYING]
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (0fcc0b495e8f8c0c6e26cf2cb476ca98) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (4/16)
(097d4214f9ed8e2b03ec133058ca3797) [DEPLOYING].
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (4/16)
(097d4214f9ed8e2b03ec133058ca3797) [DEPLOYING].
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(4/16) (097d4214f9ed8e2b03ec133058ca3797) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(4/16) (097d4214f9ed8e2b03ec133058ca3797) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(4/16) (097d4214f9ed8e2b03ec133058ca3797) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (4/16)
(097d4214f9ed8e2b03ec133058ca3797).
Oct 27, 2018 2:03:44 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@3aef037d) (4/16)
(097d4214f9ed8e2b03ec133058ca3797) [FINISHED]
Oct 27, 2018 2:03:44 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@3aef037d)
097d4214f9ed8e2b03ec133058ca3797.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(4/16) (097d4214f9ed8e2b03ec133058ca3797) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d).
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(5/16) (7bf5cf5373f1d4638614a9795187d17c) switched from CREATED to SCHEDULED.
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d) [FINISHED]
Oct 27, 2018 2:03:44 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) eb1960d9bf9521527a95c96ccd97184d.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(5/16) (7bf5cf5373f1d4638614a9795187d17c) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (5/16) (attempt
#0) to localhost
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (5/16).
Oct 27, 2018 2:03:44 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) (5/16)
(eb1960d9bf9521527a95c96ccd97184d) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(5/16) (7bf5cf5373f1d4638614a9795187d17c) switched from CREATED to DEPLOYING.
Oct 27, 2018 2:03:44 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@3aef037d) (5/16)
(7bf5cf5373f1d4638614a9795187d17c) [DEPLOYING]
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (5/16)
(7bf5cf5373f1d4638614a9795187d17c) [DEPLOYING].
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (5/16)
(7bf5cf5373f1d4638614a9795187d17c) [DEPLOYING].
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(5/16) (7bf5cf5373f1d4638614a9795187d17c) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(5/16) (7bf5cf5373f1d4638614a9795187d17c) switched from DEPLOYING to RUNNING.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(5/16) (7bf5cf5373f1d4638614a9795187d17c) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (5/16)
(7bf5cf5373f1d4638614a9795187d17c).
Oct 27, 2018 2:03:44 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@3aef037d) (5/16)
(7bf5cf5373f1d4638614a9795187d17c) [FINISHED]
Oct 27, 2018 2:03:44 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@3aef037d)
7bf5cf5373f1d4638614a9795187d17c.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(5/16) (7bf5cf5373f1d4638614a9795187d17c) switched from RUNNING to FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027020337-d0051fc3 (83d8f7029893d47dfa1431c0bc6ba0a7)
switched from state RUNNING to FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 83d8f7029893d47dfa1431c0bc6ba0a7 reached globally terminal state
FINISHED.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027020337-d0051fc3(83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 83d8f7029893d47dfa1431c0bc6ba0a7.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 081af8aef17b9d70a87d64219ca31cda:
JobManager is shutting down..
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 2:03:44 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
97a9441fb70024a4666745f593c74ec7@akka://flink/user/jobmanager_25 for job
83d8f7029893d47dfa1431c0bc6ba0a7 from the resource manager.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 2:03:44 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 83d8f7029893d47dfa1431c0bc6ba0a7 with leader id
97a9441fb70024a4666745f593c74ec7 lost leadership.
Oct 27, 2018 2:03:44 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcherc8d38656-71ef-465d-bb5a-dc0ed859e86c.
Oct 27, 2018 2:03:44 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 2:03:44 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{03c72b797d869bd919499662250f0394}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 4d11db96a4971795af535c341beacce7 from the
SlotManager.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcherc8d38656-71ef-465d-bb5a-dc0ed859e86c.
Oct 27, 2018 2:03:44 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{6596a80d9d5f707a570031476ad094b7}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{fb9b08bae1807ab4fa5e11f8584310f1}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{8d35828fe16c0cc6b40e976682356976}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{8eb96cacf59eeb577b64e94b65a34876}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{2d7e796d2c65faaa97a84090ac0fbc45}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{bf181702b15fbff68cbb0d18cefa786d}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{e3f27bb2240cc03b59107e242e64c5fe}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{119abd100855317a26830c9938f55460}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{ce2a71bc1585bbfe9a003fc444293d20}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{11bb70880c43756a8ee355ab77e0efee}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{e897e8cb7bd3b5df5a58ace332dd58cf}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{2a956a75c5f973749292aaa48cf6da45}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{01e44e85fbca1b8c052053e36df5045d}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{e51e4aa6659ea9b585b8eac1799b5dc3}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 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{f7ae48d034312b15c4960f8a86d53fda}, jobId:
83d8f7029893d47dfa1431c0bc6ba0a7).
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 83d8f7029893d47dfa1431c0bc6ba0a7 from job leader monitoring.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 83d8f7029893d47dfa1431c0bc6ba0a7.
Oct 27, 2018 2:03:44 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcherc8d38656-71ef-465d-bb5a-dc0ed859e86c.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 2:03:44 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-af40abff-0d92-4bcb-83f9-a835171e08da
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:33885
Oct 27, 2018 2:03:44 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 2:03:44 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 6047 msecs
Oct 27, 2018 2:03:44 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 2:03:44 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@89352230
2018-10-27T02:03:44.241Z Waiting for main pipeline to 'finish'
2018-10-27T02:03:44.241Z 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 24.646 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 16s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/3dnbhugxa64ce
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]
