See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/917/display/redirect?page=changes>
Changes:
[huangry] Migrate existing streaming integration test to using customized
dataflow
------------------------------------------
[...truncated 22.88 MB...]
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (16/16)
(6bb58e9b64a8fa4d4a9f427a2dbca560).
Oct 26, 2018 6:21:43 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@2fc32429) (16/16)
(6bb58e9b64a8fa4d4a9f427a2dbca560) [FINISHED]
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(9/16) (f7671dd1b1d659395d01f1dfe990e5f4) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 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) (2/16)
(d7baf1a2386b0d607838790476eb69ac) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (2/16).
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (9/16)
(f7671dd1b1d659395d01f1dfe990e5f4).
Oct 26, 2018 6:21:43 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@2fc32429) (9/16)
(f7671dd1b1d659395d01f1dfe990e5f4) [FINISHED]
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(13/16) (40580998ff76a735e6d3207bd230314a) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 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@2fc32429)
2848faac34ca10da73a28dec9ca30f17.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (0eafce9b8714f68cf32b370ae573f9a8) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(9/16) (f7671dd1b1d659395d01f1dfe990e5f4) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:21:43 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@2fc32429) (2/16)
(0eafce9b8714f68cf32b370ae573f9a8) [DEPLOYING]
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(10/16) (2848faac34ca10da73a28dec9ca30f17) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (2/16)
(0eafce9b8714f68cf32b370ae573f9a8) [DEPLOYING].
Oct 26, 2018 6:21:43 PM 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) (4/16).
Oct 26, 2018 6:21:43 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) (4/16)
(22e653fd27fdf243cf592de592f445e5) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (2/16)
(0eafce9b8714f68cf32b370ae573f9a8) [DEPLOYING].
Oct 26, 2018 6:21:43 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.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) e310ee37e13bb2f1d314122501f02d10.
Oct 26, 2018 6:21:43 PM 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) (4/16)
(22e653fd27fdf243cf592de592f445e5) [DEPLOYING]
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (0eafce9b8714f68cf32b370ae573f9a8) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:21:43 PM 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) (4/16)
(22e653fd27fdf243cf592de592f445e5) [DEPLOYING].
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (0eafce9b8714f68cf32b370ae573f9a8) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:21:43 PM 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) (4/16)
(22e653fd27fdf243cf592de592f445e5) [DEPLOYING].
Oct 26, 2018 6:21:43 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@2fc32429)
6bb58e9b64a8fa4d4a9f427a2dbca560.
Oct 26, 2018 6:21:43 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) (4/16)
(22e653fd27fdf243cf592de592f445e5) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:21:43 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@2fc32429)
f7671dd1b1d659395d01f1dfe990e5f4.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at Query12.Format/ParMultiDo(Anonymous))
-> FlatMap (FlatMap at Query12.Format/ParMultiDo(Anonymous).output) (4/16)
(e310ee37e13bb2f1d314122501f02d10) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (0eafce9b8714f68cf32b370ae573f9a8) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(16/16) (6bb58e9b64a8fa4d4a9f427a2dbca560) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (2/16)
(0eafce9b8714f68cf32b370ae573f9a8).
Oct 26, 2018 6:21:43 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@2fc32429) (2/16)
(0eafce9b8714f68cf32b370ae573f9a8) [FINISHED]
Oct 26, 2018 6:21:43 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) (4/16)
(22e653fd27fdf243cf592de592f445e5) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:21:43 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@2fc32429)
0eafce9b8714f68cf32b370ae573f9a8.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(9/16) (f7671dd1b1d659395d01f1dfe990e5f4) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(2/16) (0eafce9b8714f68cf32b370ae573f9a8) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 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) (4/16)
(22e653fd27fdf243cf592de592f445e5) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 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) (4/16)
(22e653fd27fdf243cf592de592f445e5).
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(4/16) (ec9879f06b197a39570117a947d978c7) switched from CREATED to SCHEDULED.
Oct 26, 2018 6:21:43 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) (4/16)
(22e653fd27fdf243cf592de592f445e5) [FINISHED]
Oct 26, 2018 6:21:43 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) 22e653fd27fdf243cf592de592f445e5.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(4/16) (ec9879f06b197a39570117a947d978c7) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (4/16) (attempt
#0) to localhost
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (4/16).
Oct 26, 2018 6:21:43 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) (4/16)
(22e653fd27fdf243cf592de592f445e5) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(4/16) (ec9879f06b197a39570117a947d978c7) switched from CREATED to DEPLOYING.
Oct 26, 2018 6:21:43 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@2fc32429) (4/16)
(ec9879f06b197a39570117a947d978c7) [DEPLOYING]
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (4/16)
(ec9879f06b197a39570117a947d978c7) [DEPLOYING].
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (4/16)
(ec9879f06b197a39570117a947d978c7) [DEPLOYING].
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(4/16) (ec9879f06b197a39570117a947d978c7) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(4/16) (ec9879f06b197a39570117a947d978c7) switched from DEPLOYING to RUNNING.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(4/16) (ec9879f06b197a39570117a947d978c7) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429) (4/16)
(ec9879f06b197a39570117a947d978c7).
Oct 26, 2018 6:21:43 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@2fc32429) (4/16)
(ec9879f06b197a39570117a947d978c7) [FINISHED]
Oct 26, 2018 6:21:43 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@2fc32429)
ec9879f06b197a39570117a947d978c7.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2fc32429)
(4/16) (ec9879f06b197a39570117a947d978c7) switched from RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1026182137-61175e08 (898e2aa7ae0edb14b1ca561becc32bc0)
switched from state RUNNING to FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 898e2aa7ae0edb14b1ca561becc32bc0 reached globally terminal state
FINISHED.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1026182137-61175e08(898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 898e2aa7ae0edb14b1ca561becc32bc0.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 8e9333e5c52bcfb3b5d941ca8ca9c78d:
JobManager is shutting down..
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 26, 2018 6:21:43 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
b25abae60f9241d06b3a1521b6a44f92@akka://flink/user/jobmanager_25 for job
898e2aa7ae0edb14b1ca561becc32bc0 from the resource manager.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 26, 2018 6:21:43 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 898e2aa7ae0edb14b1ca561becc32bc0 with leader id
b25abae60f9241d06b3a1521b6a44f92 lost leadership.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatchera24566e9-e7bf-45fa-af0d-0d6994860039.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatchera24566e9-e7bf-45fa-af0d-0d6994860039.
Oct 26, 2018 6:21:43 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{7e0b1955c1ea7cc72519575f0ede66d6}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 26, 2018 6:21:43 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 26, 2018 6:21:43 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 849092a7d5b11dad9a13cb444a555c39 from the
SlotManager.
Oct 26, 2018 6:21:43 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{eb679c273f785341d602d2388abc6702}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{788f982a91ee4c01480d9ad97cce0f78}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{b115446df9386b92706a710d80ddd07c}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{ff1721195d12c078b6f6abae356a789d}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{954b76453aed80bea66a033fd1b2d486}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{21a429cb3b3d42bd9d22f2c40001b0be}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{62bc2e90575aa7067227aadee2e6d6e1}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{9cb4c8d84a5f52fe70019010ec1a321c}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{47ce1fa9f936a8b2b2adb077222ea4a8}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{7a5fcede234ee728aa640494b91fdf3a}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{75989b73228037f6f4dd36947308054b}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{d33507417ec35b23ce9e1fa6d5960364}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{bcaf05163c67dfbc2f3bf84665d6614b}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{d4f9a4c7992802e207f2cf0862998346}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 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{2f8882e7e4856239539d68a0ce417354}, jobId:
898e2aa7ae0edb14b1ca561becc32bc0).
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 898e2aa7ae0edb14b1ca561becc32bc0 from job leader monitoring.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 898e2aa7ae0edb14b1ca561becc32bc0.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 6:21:43 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 26, 2018 6:21:43 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatchera24566e9-e7bf-45fa-af0d-0d6994860039.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-d8d796e4-741d-456c-b598-9d1b2f34bcab
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:37889
Oct 26, 2018 6:21:43 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 26, 2018 6:21:43 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5818 msecs
Oct 26, 2018 6:21:43 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 26, 2018 6:21:43 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@68ae5f5a
2018-10-26T18:21:43.900Z Waiting for main pipeline to 'finish'
2018-10-26T18:21:43.900Z 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 26.513 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/madjdzqwul66m
Build cache (/home/jenkins/.gradle/caches/build-cache-1) removing files not
accessed on or after Fri Oct 19 18:17:35 UTC 2018.
Cache entries evicted. In-memory cache of
/home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4288}
MaxSize{4500}, CacheStats{hitCount=15, missCount=3910, loadSuccessCount=3911,
loadExceptionCount=0, totalLoadTime=278148661, evictionCount=1}
Performance may suffer from in-memory cache misses. Increase max heap size of
Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of
/home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500}
MaxSize{4500}, CacheStats{hitCount=17, missCount=4572, loadSuccessCount=4573,
loadExceptionCount=0, totalLoadTime=315638349, evictionCount=451}
Performance may suffer from in-memory cache misses. Increase max heap size of
Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of
/home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500}
MaxSize{4500}, CacheStats{hitCount=17, missCount=5022, loadSuccessCount=5023,
loadExceptionCount=0, totalLoadTime=345925048, evictionCount=901}
Performance may suffer from in-memory cache misses. Increase max heap size of
Gradle build process to reduce cache misses.
Build cache (/home/jenkins/.gradle/caches/build-cache-1) cleaned up in 0.629
secs.
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]
