See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/931/display/redirect>
------------------------------------------
[...truncated 22.95 MB...]
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(5/16) (894f9ce851e54b7f3de64afb3375594a) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (5/16) (attempt
#0) to localhost
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (10/16)
(18077c7b0a702b7f4ba9f5da2ef8e241) [DEPLOYING].
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (15/16).
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (10/16)
(18077c7b0a702b7f4ba9f5da2ef8e241) [DEPLOYING].
Oct 27, 2018 12:08:22 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) (15/16)
(5c08a46bed825dc242b56529057759fa) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(10/16) (18077c7b0a702b7f4ba9f5da2ef8e241) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(10/16) (18077c7b0a702b7f4ba9f5da2ef8e241) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(10/16) (18077c7b0a702b7f4ba9f5da2ef8e241) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (10/16)
(18077c7b0a702b7f4ba9f5da2ef8e241).
Oct 27, 2018 12:08:22 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@6ce3815f) (10/16)
(18077c7b0a702b7f4ba9f5da2ef8e241) [FINISHED]
Oct 27, 2018 12:08:22 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@6ce3815f)
35f1677958f8172e5c8b499e1b879ecc.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(15/16) (b7054f0b2338ed0857b2fdbf9c77333c) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:08:22 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@6ce3815f) (15/16)
(b7054f0b2338ed0857b2fdbf9c77333c) [DEPLOYING]
Oct 27, 2018 12:08:22 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) ae485091701135bdb8248f7446368a99.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (15/16)
(b7054f0b2338ed0857b2fdbf9c77333c) [DEPLOYING].
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(6/16) (35f1677958f8172e5c8b499e1b879ecc) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (15/16)
(b7054f0b2338ed0857b2fdbf9c77333c) [DEPLOYING].
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (9/16).
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(15/16) (b7054f0b2338ed0857b2fdbf9c77333c) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:22 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@6ce3815f)
aebc0832172d6faa43d3dcae6294bf3a.
Oct 27, 2018 12:08:22 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)
(ae485091701135bdb8248f7446368a99) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(9/16) (474a785c1afde63c49476919fd3e177e) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:08:22 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@6ce3815f)
d7310f7115acf6f4fbd8b99355c7c1a8.
Oct 27, 2018 12:08:22 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@6ce3815f) (9/16)
(474a785c1afde63c49476919fd3e177e) [DEPLOYING]
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (9/16)
(474a785c1afde63c49476919fd3e177e) [DEPLOYING].
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(15/16) (b7054f0b2338ed0857b2fdbf9c77333c) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:22 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) 96117e6adf344309d3f271c11565fcc7.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(15/16) (b7054f0b2338ed0857b2fdbf9c77333c) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (15/16)
(b7054f0b2338ed0857b2fdbf9c77333c).
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (9/16)
(474a785c1afde63c49476919fd3e177e) [DEPLOYING].
Oct 27, 2018 12:08:22 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@6ce3815f) (15/16)
(b7054f0b2338ed0857b2fdbf9c77333c) [FINISHED]
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(14/16) (aebc0832172d6faa43d3dcae6294bf3a) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(9/16) (474a785c1afde63c49476919fd3e177e) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(7/16) (d7310f7115acf6f4fbd8b99355c7c1a8) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(9/16) (474a785c1afde63c49476919fd3e177e) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (9/16)
(474a785c1afde63c49476919fd3e177e).
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (5/16).
Oct 27, 2018 12:08:22 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@6ce3815f) (9/16)
(474a785c1afde63c49476919fd3e177e) [FINISHED]
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(5/16) (894f9ce851e54b7f3de64afb3375594a) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:08:22 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) (5/16)
(96117e6adf344309d3f271c11565fcc7) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 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@6ce3815f)
18077c7b0a702b7f4ba9f5da2ef8e241.
Oct 27, 2018 12:08:22 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@6ce3815f) (5/16)
(894f9ce851e54b7f3de64afb3375594a) [DEPLOYING]
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(9/16) (474a785c1afde63c49476919fd3e177e) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:22 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@6ce3815f)
b7054f0b2338ed0857b2fdbf9c77333c.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (5/16)
(894f9ce851e54b7f3de64afb3375594a) [DEPLOYING].
Oct 27, 2018 12:08:22 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@6ce3815f)
474a785c1afde63c49476919fd3e177e.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(10/16) (18077c7b0a702b7f4ba9f5da2ef8e241) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(15/16) (b7054f0b2338ed0857b2fdbf9c77333c) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (5/16)
(894f9ce851e54b7f3de64afb3375594a) [DEPLOYING].
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(5/16) (894f9ce851e54b7f3de64afb3375594a) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(9/16) (474a785c1afde63c49476919fd3e177e) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(5/16) (894f9ce851e54b7f3de64afb3375594a) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(5/16) (894f9ce851e54b7f3de64afb3375594a) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (5/16)
(894f9ce851e54b7f3de64afb3375594a).
Oct 27, 2018 12:08:22 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@6ce3815f) (5/16)
(894f9ce851e54b7f3de64afb3375594a) [FINISHED]
Oct 27, 2018 12:08:22 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@6ce3815f)
894f9ce851e54b7f3de64afb3375594a.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(5/16) (894f9ce851e54b7f3de64afb3375594a) switched from RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027120816-a75fb715 (e8c1f9776bb24346f7fa7088094852fa)
switched from state RUNNING to FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job e8c1f9776bb24346f7fa7088094852fa reached globally terminal state
FINISHED.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027120816-a75fb715(e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job e8c1f9776bb24346f7fa7088094852fa.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection d8fb7eeb4f3fd808e3f2b8e1158c0fe9:
JobManager is shutting down..
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 12:08:22 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
bf961933e8e13edee6e7916f9a3f4dd9@akka://flink/user/jobmanager_25 for job
e8c1f9776bb24346f7fa7088094852fa from the resource manager.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 12:08:22 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job e8c1f9776bb24346f7fa7088094852fa with leader id
bf961933e8e13edee6e7916f9a3f4dd9 lost leadership.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher58977d22-5bc3-4b9e-894e-5971c9fa5ba6.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher58977d22-5bc3-4b9e-894e-5971c9fa5ba6.
Oct 27, 2018 12:08:22 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 12:08:22 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{6f0c4a9c3e3ef28658bc637417d51c2b}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 12:08:22 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 9844ae3ffeafa03d25baabd006675272 from the
SlotManager.
Oct 27, 2018 12:08:22 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{92f2cd15ead745952c943adcb6fbaf06}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{c203bbb62840ab39ebaf06f08a1dfdf2}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher58977d22-5bc3-4b9e-894e-5971c9fa5ba6.
Oct 27, 2018 12:08:22 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{105d6441ae8557460c368a0dc2efb77f}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{81b4cd5aa62ca4a50b7ce2a9b01f99cf}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{3b23e99d38dc0233e4cf42dd279085a0}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{113401cf466f75ead43759c379f0b175}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{02a562bc6b6905f5bab4e2b71cdaf70e}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{105783e8b4f31d5a4254911c55eb604c}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{b2b5d71190da333fe6e66cf6695625b2}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{78fc8869485e2191615237ed6a59616b}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{4ac629137db224f57faa228d87ac430b}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{1c350e492d238ec02c1cf2c216f127f0}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{c9c9edce5787b523b7c30df4b7789643}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 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{58ef0810950eac850d40e6cfdc871d66}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 12:08:22 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{c586e36e9cf09010a488a0af3c60d227}, jobId:
e8c1f9776bb24346f7fa7088094852fa).
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job e8c1f9776bb24346f7fa7088094852fa from job leader monitoring.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job e8c1f9776bb24346f7fa7088094852fa.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job e8c1f9776bb24346f7fa7088094852fa.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 12:08:22 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-c82807f0-e432-40ee-8e6f-9bc3967077c1
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:45697
Oct 27, 2018 12:08:22 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 12:08:22 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5377 msecs
Oct 27, 2018 12:08:22 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 12:08:22 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@949b94e7
2018-10-27T12:08:22.898Z Waiting for main pipeline to 'finish'
2018-10-27T12:08:22.898Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 10,5,main])
completed. Took 1 mins 24.613 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-nexmark:run'.
> Process 'command '/usr/local/asfpackages/java/jdk1.8.0_172/bin/java''
> finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 4m 17s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/b675wwwrykn4i
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]
