See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/919/display/redirect?page=changes>
Changes:
[github] Update web site links for the 2.8.0 release (#6745)
------------------------------------------
[...truncated 22.88 MB...]
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (13/16)
(6f33dff7bf93420fc7b95ae747c80402) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (13/16)
(6f33dff7bf93420fc7b95ae747c80402).
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (5/16).
Oct 26, 2018 6:52:25 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)
(32db81935c70d4d38c9a583fa7bf6cda) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (13/16)
(6f33dff7bf93420fc7b95ae747c80402) [FINISHED]
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(8/16) (85c16d191f35af9a941f8271993f185a) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (8/16)
(85c16d191f35af9a941f8271993f185a).
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(8/16) (85c16d191f35af9a941f8271993f185a) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:52:25 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@153cf964) (8/16)
(85c16d191f35af9a941f8271993f185a) [FINISHED]
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (cce89c653498861534833d926c0420e4) switched from CREATED to SCHEDULED.
Oct 26, 2018 6:52:25 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) 6f33dff7bf93420fc7b95ae747c80402.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(5/16) (6dd9e14174f29a701969a744b739131a) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:52:25 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@153cf964) (5/16)
(6dd9e14174f29a701969a744b739131a) [DEPLOYING]
Oct 26, 2018 6:52:25 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) (12/16)
(e1dc6a37c5cc7261b61f33dc112a4cda) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (5/16)
(6dd9e14174f29a701969a744b739131a) [DEPLOYING].
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (d907a9690cad62d701427d0c362a5bbc) switched from CREATED to SCHEDULED.
Oct 26, 2018 6:52:25 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@153cf964)
85c16d191f35af9a941f8271993f185a.
Oct 26, 2018 6:52:25 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) (12/16)
(e1dc6a37c5cc7261b61f33dc112a4cda).
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (cce89c653498861534833d926c0420e4) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (5/16)
(6dd9e14174f29a701969a744b739131a) [DEPLOYING].
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (13/16) (attempt
#0) to localhost
Oct 26, 2018 6:52:25 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) (12/16)
(e1dc6a37c5cc7261b61f33dc112a4cda) [FINISHED]
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (d907a9690cad62d701427d0c362a5bbc) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (13/16)
(6f33dff7bf93420fc7b95ae747c80402) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(5/16) (6dd9e14174f29a701969a744b739131a) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16) (attempt
#0) to localhost
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(8/16) (85c16d191f35af9a941f8271993f185a) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (13/16).
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(5/16) (6dd9e14174f29a701969a744b739131a) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(5/16) (6dd9e14174f29a701969a744b739131a) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (5/16)
(6dd9e14174f29a701969a744b739131a).
Oct 26, 2018 6:52:25 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) e1dc6a37c5cc7261b61f33dc112a4cda.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (cce89c653498861534833d926c0420e4) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:52:25 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@153cf964) (5/16)
(6dd9e14174f29a701969a744b739131a) [FINISHED]
Oct 26, 2018 6:52:25 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@153cf964) (13/16)
(cce89c653498861534833d926c0420e4) [DEPLOYING]
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (13/16)
(cce89c653498861534833d926c0420e4) [DEPLOYING].
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16).
Oct 26, 2018 6:52:25 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) (12/16)
(e1dc6a37c5cc7261b61f33dc112a4cda) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (13/16)
(cce89c653498861534833d926c0420e4) [DEPLOYING].
Oct 26, 2018 6:52:25 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@153cf964)
6dd9e14174f29a701969a744b739131a.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (d907a9690cad62d701427d0c362a5bbc) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (cce89c653498861534833d926c0420e4) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:52:25 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@153cf964) (12/16)
(d907a9690cad62d701427d0c362a5bbc) [DEPLOYING]
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16)
(d907a9690cad62d701427d0c362a5bbc) [DEPLOYING].
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(5/16) (6dd9e14174f29a701969a744b739131a) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16)
(d907a9690cad62d701427d0c362a5bbc) [DEPLOYING].
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (cce89c653498861534833d926c0420e4) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (d907a9690cad62d701427d0c362a5bbc) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (cce89c653498861534833d926c0420e4) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (d907a9690cad62d701427d0c362a5bbc) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (13/16)
(cce89c653498861534833d926c0420e4).
Oct 26, 2018 6:52:25 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@153cf964) (13/16)
(cce89c653498861534833d926c0420e4) [FINISHED]
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (d907a9690cad62d701427d0c362a5bbc) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 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@153cf964)
cce89c653498861534833d926c0420e4.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16)
(d907a9690cad62d701427d0c362a5bbc).
Oct 26, 2018 6:52:25 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@153cf964) (12/16)
(d907a9690cad62d701427d0c362a5bbc) [FINISHED]
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (cce89c653498861534833d926c0420e4) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 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@153cf964)
d907a9690cad62d701427d0c362a5bbc.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (d907a9690cad62d701427d0c362a5bbc) switched from RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1026185219-66f5e6e1 (79957ae373d149333e5533febf9c08d6)
switched from state RUNNING to FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 79957ae373d149333e5533febf9c08d6 reached globally terminal state
FINISHED.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1026185219-66f5e6e1(79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 79957ae373d149333e5533febf9c08d6.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 3913e19d3a4073ec498772434f367ecb:
JobManager is shutting down..
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 26, 2018 6:52:25 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
8025be24e35ec57de279b2ad24c54940@akka://flink/user/jobmanager_25 for job
79957ae373d149333e5533febf9c08d6 from the resource manager.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 26, 2018 6:52:25 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 79957ae373d149333e5533febf9c08d6 with leader id
8025be24e35ec57de279b2ad24c54940 lost leadership.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcherdad95c27-3da0-4a72-bf21-065b6fafd91f.
Oct 26, 2018 6:52:25 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcherdad95c27-3da0-4a72-bf21-065b6fafd91f.
Oct 26, 2018 6:52:25 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 26, 2018 6:52:25 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{564b168c87159b0899ba4b90a23b9ae5}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 89370dc7d4200b7326f743a15a78f298 from the
SlotManager.
Oct 26, 2018 6:52:25 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{830a7edba47d9e00df48b3000917c0ea}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{a2eac93a8d4c24565d327dc0c78a3ae5}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{fd51875c040434459a06ae8514d5318a}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 26, 2018 6:52:25 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{7d4d750eb68f8e0e75bab46e736d0541}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcherdad95c27-3da0-4a72-bf21-065b6fafd91f.
Oct 26, 2018 6:52:25 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{cfe52150fb31a1e10c3b04248fe4515c}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{ad0876304951e6c863cca5e6f3731817}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{aa5a84756ca513b29a82417b10a4fe52}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{49c759b15258cb80c22f0ce2d867493c}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{dace3e587a35c2ade0643fadf359ed37}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{12a9169c092a19ab502c931e28414457}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{d5e8277bcccee69118158c76f0d66b4e}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{cd0930df3c39d7cd44f9e9127fcf7760}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{59bb69505b560a3a54db258c6bc0a4ec}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{b93f2ae210e7b91e012681c87bc1b8c9}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 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{a5eec4ea87f7d57deb6551e7ad3895e5}, jobId:
79957ae373d149333e5533febf9c08d6).
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 79957ae373d149333e5533febf9c08d6 from job leader monitoring.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 79957ae373d149333e5533febf9c08d6.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 6:52:25 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-732f4d0d-d29b-41c7-b487-ce47592b27f9
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:41355
Oct 26, 2018 6:52:25 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 26, 2018 6:52:25 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5647 msecs
Oct 26, 2018 6:52:25 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 26, 2018 6:52:25 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@9eff92a9
2018-10-26T18:52:25.740Z Waiting for main pipeline to 'finish'
2018-10-26T18:52:25.740Z 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 28.291 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/yovqtgeyfpqyo
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]
