See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/920/display/redirect?page=changes>
Changes:
[lcwik] Migrate to using the full Gradle distribution rather than binary-only.
------------------------------------------
[...truncated 22.88 MB...]
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(14/16) (ad92889dfada647699a064662aaef8a7) switched from CREATED to DEPLOYING.
Oct 26, 2018 7:58:48 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) (2/16)
(cb3017816d0495882cb735a96dbdcfde) [FINISHED]
Oct 26, 2018 7:58:48 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) (14/16)
(ad92889dfada647699a064662aaef8a7) [DEPLOYING]
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12/Query12.Stamp/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12/Query12.Stamp/ParMultiDo(Anonymous).output) (13/16)
(89ff5f4c171240c3c92b4d6a729afb21) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (14/16)
(ad92889dfada647699a064662aaef8a7) [DEPLOYING].
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task CHAIN MapPartition (MapPartition at
Query12.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) (13/16).
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at Query12.Format/ParMultiDo(Anonymous))
-> FlatMap (FlatMap at Query12.Format/ParMultiDo(Anonymous).output) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8) switched from CREATED to DEPLOYING.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (14/16)
(ad92889dfada647699a064662aaef8a7) [DEPLOYING].
Oct 26, 2018 7:58:48 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)
9cf4861bb85326e032539a7dd2f6665b.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(14/16) (ad92889dfada647699a064662aaef8a7) switched from DEPLOYING to RUNNING.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task CHAIN MapPartition
(MapPartition at Query12.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8) [DEPLOYING]
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at
Query12.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8) [DEPLOYING].
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(14/16) (ad92889dfada647699a064662aaef8a7) switched from DEPLOYING to RUNNING.
Oct 26, 2018 7:58:48 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)
cb3017816d0495882cb735a96dbdcfde.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: CHAIN MapPartition (MapPartition at
Query12.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8) [DEPLOYING].
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(11/16) (9cf4861bb85326e032539a7dd2f6665b) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at Query12.Format/ParMultiDo(Anonymous))
-> FlatMap (FlatMap at Query12.Format/ParMultiDo(Anonymous).output) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8) switched from DEPLOYING to RUNNING.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(2/16) (cb3017816d0495882cb735a96dbdcfde) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(14/16) (ad92889dfada647699a064662aaef8a7) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 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) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8) switched from DEPLOYING to RUNNING.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (14/16)
(ad92889dfada647699a064662aaef8a7).
Oct 26, 2018 7:58:48 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) (14/16)
(ad92889dfada647699a064662aaef8a7) [FINISHED]
Oct 26, 2018 7:58:48 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)
ad92889dfada647699a064662aaef8a7.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(14/16) (ad92889dfada647699a064662aaef8a7) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 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)
(34d4722c85488b0e6eec337766e247f3) switched from CREATED to SCHEDULED.
Oct 26, 2018 7:58:48 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)
(34d4722c85488b0e6eec337766e247f3) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (13/16) (attempt #0) to localhost
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at Query12.Format/ParMultiDo(Anonymous))
-> FlatMap (FlatMap at Query12.Format/ParMultiDo(Anonymous).output) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at
Query12.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8).
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at Query12.Format/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.Format/ParMultiDo(Anonymous).output) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8) [FINISHED]
Oct 26, 2018 7:58:48 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) (13/16).
Oct 26, 2018 7:58:48 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) da1e6ec3cd5f341a06230483aaca22d8.
Oct 26, 2018 7:58:48 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)
(34d4722c85488b0e6eec337766e247f3) switched from CREATED to DEPLOYING.
Oct 26, 2018 7:58:48 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) (13/16)
(34d4722c85488b0e6eec337766e247f3) [DEPLOYING]
Oct 26, 2018 7:58:48 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) (13/16)
(34d4722c85488b0e6eec337766e247f3) [DEPLOYING].
Oct 26, 2018 7:58:48 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) (13/16)
(da1e6ec3cd5f341a06230483aaca22d8) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 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) (13/16)
(34d4722c85488b0e6eec337766e247f3) [DEPLOYING].
Oct 26, 2018 7:58:48 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)
(34d4722c85488b0e6eec337766e247f3) switched from DEPLOYING to RUNNING.
Oct 26, 2018 7:58:48 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)
(34d4722c85488b0e6eec337766e247f3) switched from DEPLOYING to RUNNING.
Oct 26, 2018 7:58:48 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)
(34d4722c85488b0e6eec337766e247f3) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 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)
(34d4722c85488b0e6eec337766e247f3).
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (93fd9d61b076aa9e1ecdc190aaea1e18) switched from CREATED to SCHEDULED.
Oct 26, 2018 7:58:48 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)
(34d4722c85488b0e6eec337766e247f3) [FINISHED]
Oct 26, 2018 7:58:48 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) 34d4722c85488b0e6eec337766e247f3.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (93fd9d61b076aa9e1ecdc190aaea1e18) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 7:58:48 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 7:58:48 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)
(34d4722c85488b0e6eec337766e247f3) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 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 7:58:48 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (93fd9d61b076aa9e1ecdc190aaea1e18) switched from CREATED to DEPLOYING.
Oct 26, 2018 7:58:48 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)
(93fd9d61b076aa9e1ecdc190aaea1e18) [DEPLOYING]
Oct 26, 2018 7:58:48 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)
(93fd9d61b076aa9e1ecdc190aaea1e18) [DEPLOYING].
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (13/16)
(93fd9d61b076aa9e1ecdc190aaea1e18) [DEPLOYING].
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (93fd9d61b076aa9e1ecdc190aaea1e18) switched from DEPLOYING to RUNNING.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (93fd9d61b076aa9e1ecdc190aaea1e18) switched from DEPLOYING to RUNNING.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (93fd9d61b076aa9e1ecdc190aaea1e18) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (13/16)
(93fd9d61b076aa9e1ecdc190aaea1e18).
Oct 26, 2018 7:58:48 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)
(93fd9d61b076aa9e1ecdc190aaea1e18) [FINISHED]
Oct 26, 2018 7:58:48 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)
93fd9d61b076aa9e1ecdc190aaea1e18.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(13/16) (93fd9d61b076aa9e1ecdc190aaea1e18) switched from RUNNING to FINISHED.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1026195842-8acc634f (be662d10c33dfc17d2f7ab3a02a2d2b0)
switched from state RUNNING to FINISHED.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job be662d10c33dfc17d2f7ab3a02a2d2b0 reached globally terminal state
FINISHED.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1026195842-8acc634f(be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job be662d10c33dfc17d2f7ab3a02a2d2b0.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection e612cee770aeb37f36a1d3f0c7461d5b:
JobManager is shutting down..
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 26, 2018 7:58:48 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
a43edf69d32e41cdabc1c6d976524d8b@akka://flink/user/jobmanager_25 for job
be662d10c33dfc17d2f7ab3a02a2d2b0 from the resource manager.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 26, 2018 7:58:48 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job be662d10c33dfc17d2f7ab3a02a2d2b0 with leader id
a43edf69d32e41cdabc1c6d976524d8b lost leadership.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher2fe8ae6a-3d45-4b46-a970-53cfcc9cbb16.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher2fe8ae6a-3d45-4b46-a970-53cfcc9cbb16.
Oct 26, 2018 7:58:48 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 26, 2018 7:58:48 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 26, 2018 7:58:48 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager b62b20f7c091a748aa24277595ff9e7d from the
SlotManager.
Oct 26, 2018 7:58:48 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{35764b496c80538ae9dfcbad0412c694}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{d4d7bcb7a8ef43a26123276d842a17f4}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{964229cc3d1bd3c7ba19589e22731a4d}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{8bfa482562e736d1eb59edcd8daa391b}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher2fe8ae6a-3d45-4b46-a970-53cfcc9cbb16.
Oct 26, 2018 7:58:48 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{db443e91b28c7590f5f6505c005fc9c8}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{ac01ad42bead98ead3204302ab3db97c}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{d8e04bddf77f6fe799f984efbdedbe08}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{06a199669bbb9f2b71f7f68b5e00cc2f}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{869a9bf50f204bb0cf65061c1c1c013b}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{2e8a147b1b87673ff7f1c6f19253e614}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{e0706da070543377ad8e6b395b8019a7}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{71b1cd6d33730f50237fd03cd3b319c4}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{7b8bd9a5ad6205a87c3c6553b9086e42}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{661a093dfe9ddeb6b86c21259a848097}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 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{49efce11141eade0839f0a4ad12197f2}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 26, 2018 7:58:48 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{fc2a2e49656e254d290e39f1fc46877e}, jobId:
be662d10c33dfc17d2f7ab3a02a2d2b0).
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job be662d10c33dfc17d2f7ab3a02a2d2b0 from job leader monitoring.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job be662d10c33dfc17d2f7ab3a02a2d2b0.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 7:58:48 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-1ddc673d-8e15-4fc4-8eba-b53110515fe9
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:46845
Oct 26, 2018 7:58:48 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 26, 2018 7:58:48 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5785 msecs
Oct 26, 2018 7:58:48 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 26, 2018 7:58:48 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@9eff92a9
2018-10-26T19:58:48.604Z Waiting for main pipeline to 'finish'
2018-10-26T19:58:48.604Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 3,5,main])
completed. Took 1 mins 25.502 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 18s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/vk4fgasezu5pg
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]
