See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/921/display/redirect?page=changes>
Changes:
[amaliujia] apply spotless
------------------------------------------
[...truncated 22.88 MB...]
Oct 26, 2018 8:18:50 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) (6/16)
(09ec40a68bdf515054a94526fbbdb7e2).
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (8ce8f221dc53fc038764c0b2faca153f) switched from CREATED to SCHEDULED.
Oct 26, 2018 8:18:50 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) (6/16)
(09ec40a68bdf515054a94526fbbdb7e2) [FINISHED]
Oct 26, 2018 8:18:50 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) 09ec40a68bdf515054a94526fbbdb7e2.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (8ce8f221dc53fc038764c0b2faca153f) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (6/16) (attempt
#0) to localhost
Oct 26, 2018 8:18:50 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) (1/16)
(5ac55ece8ecb6586cd3042d8cf055c36) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 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) (1/16)
(5ac55ece8ecb6586cd3042d8cf055c36).
Oct 26, 2018 8:18:50 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) (1/16)
(5ac55ece8ecb6586cd3042d8cf055c36) [FINISHED]
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (6/16).
Oct 26, 2018 8:18:50 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) (6/16)
(09ec40a68bdf515054a94526fbbdb7e2) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 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) 5ac55ece8ecb6586cd3042d8cf055c36.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(1/16) (2d411693aad7fcb19734774e755cb40e) switched from CREATED to SCHEDULED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (8ce8f221dc53fc038764c0b2faca153f) switched from CREATED to DEPLOYING.
Oct 26, 2018 8:18:50 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@a961a70) (6/16)
(8ce8f221dc53fc038764c0b2faca153f) [DEPLOYING]
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (6/16)
(8ce8f221dc53fc038764c0b2faca153f) [DEPLOYING].
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(1/16) (2d411693aad7fcb19734774e755cb40e) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (6/16)
(8ce8f221dc53fc038764c0b2faca153f) [DEPLOYING].
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (1/16) (attempt
#0) to localhost
Oct 26, 2018 8:18:50 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) (1/16)
(5ac55ece8ecb6586cd3042d8cf055c36) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (8ce8f221dc53fc038764c0b2faca153f) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (8ce8f221dc53fc038764c0b2faca153f) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (1/16).
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (8ce8f221dc53fc038764c0b2faca153f) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (6/16)
(8ce8f221dc53fc038764c0b2faca153f).
Oct 26, 2018 8:18:50 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@a961a70) (6/16)
(8ce8f221dc53fc038764c0b2faca153f) [FINISHED]
Oct 26, 2018 8:18:50 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@a961a70)
8ce8f221dc53fc038764c0b2faca153f.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(1/16) (2d411693aad7fcb19734774e755cb40e) switched from CREATED to DEPLOYING.
Oct 26, 2018 8:18:50 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@a961a70) (1/16)
(2d411693aad7fcb19734774e755cb40e) [DEPLOYING]
Oct 26, 2018 8:18:50 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) (15/16)
(c4741eae8122430cc453c12915e5b330) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (1/16)
(2d411693aad7fcb19734774e755cb40e) [DEPLOYING].
Oct 26, 2018 8:18:50 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) (15/16)
(c4741eae8122430cc453c12915e5b330).
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(15/16) (ed9bc533641c21f6de25509d2d2dce8a) switched from CREATED to SCHEDULED.
Oct 26, 2018 8:18:50 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) (15/16)
(c4741eae8122430cc453c12915e5b330) [FINISHED]
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (1/16)
(2d411693aad7fcb19734774e755cb40e) [DEPLOYING].
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (8ce8f221dc53fc038764c0b2faca153f) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 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) c4741eae8122430cc453c12915e5b330.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(1/16) (2d411693aad7fcb19734774e755cb40e) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(15/16) (ed9bc533641c21f6de25509d2d2dce8a) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(1/16) (2d411693aad7fcb19734774e755cb40e) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16) (attempt
#0) to localhost
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(1/16) (2d411693aad7fcb19734774e755cb40e) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (1/16)
(2d411693aad7fcb19734774e755cb40e).
Oct 26, 2018 8:18:50 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@a961a70) (1/16)
(2d411693aad7fcb19734774e755cb40e) [FINISHED]
Oct 26, 2018 8:18:50 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)
(c4741eae8122430cc453c12915e5b330) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16).
Oct 26, 2018 8:18:50 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@a961a70)
2d411693aad7fcb19734774e755cb40e.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(15/16) (ed9bc533641c21f6de25509d2d2dce8a) switched from CREATED to DEPLOYING.
Oct 26, 2018 8:18:50 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@a961a70) (15/16)
(ed9bc533641c21f6de25509d2d2dce8a) [DEPLOYING]
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(1/16) (2d411693aad7fcb19734774e755cb40e) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16)
(ed9bc533641c21f6de25509d2d2dce8a) [DEPLOYING].
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16)
(ed9bc533641c21f6de25509d2d2dce8a) [DEPLOYING].
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(15/16) (ed9bc533641c21f6de25509d2d2dce8a) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(15/16) (ed9bc533641c21f6de25509d2d2dce8a) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(15/16) (ed9bc533641c21f6de25509d2d2dce8a) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16)
(ed9bc533641c21f6de25509d2d2dce8a).
Oct 26, 2018 8:18:50 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@a961a70) (15/16)
(ed9bc533641c21f6de25509d2d2dce8a) [FINISHED]
Oct 26, 2018 8:18:50 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@a961a70)
ed9bc533641c21f6de25509d2d2dce8a.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(15/16) (ed9bc533641c21f6de25509d2d2dce8a) switched from RUNNING to FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1026201843-75769f7f (cb3c57d0a3700c1e3b37ccf8453ebc4d)
switched from state RUNNING to FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job cb3c57d0a3700c1e3b37ccf8453ebc4d reached globally terminal state
FINISHED.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1026201843-75769f7f(cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job cb3c57d0a3700c1e3b37ccf8453ebc4d.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 1b048ea8709cff9c77529fd6f50f74de:
JobManager is shutting down..
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 26, 2018 8:18:50 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
927ca7f17f452bb8cfb9b87dbca247ea@akka://flink/user/jobmanager_25 for job
cb3c57d0a3700c1e3b37ccf8453ebc4d from the resource manager.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher12dffe09-3cc5-4bf7-a219-e80e62f9853e.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher12dffe09-3cc5-4bf7-a219-e80e62f9853e.
Oct 26, 2018 8:18:50 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 26, 2018 8:18:50 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 26, 2018 8:18:50 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job cb3c57d0a3700c1e3b37ccf8453ebc4d with leader id
927ca7f17f452bb8cfb9b87dbca247ea lost leadership.
Oct 26, 2018 8:18:50 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 1f69496508fc58ffd60a75676e874259 from the
SlotManager.
Oct 26, 2018 8:18:50 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{aeeb6e35918014eca6e4906c112dcb9c}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{fcd56c46471e06c15bbba4a48f607d29}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher12dffe09-3cc5-4bf7-a219-e80e62f9853e.
Oct 26, 2018 8:18:50 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{4b5366c37454646d91ace417827f61bc}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{07e48b8db2c9784c69aba7d0a1b7eea9}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{e6a20c9954ca87554257fe372b11fd12}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{919f088ed8b25b51882a9231ef9f119d}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{a7cff3edaa0df4e56a2b1ec0b7f26c83}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{e26f2b8e53929f3636c63c94179094d3}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{d1b2f0ef0c5ec481f59403a8e0c36bb9}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{080aed2f57dc874520c36a402af67d7d}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{9c6c21ae5b411fa3f18f424c6d8efbd7}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{35398117dffcf1134173101c27ff994a}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{02302d41e07ed87d0c56385728637f41}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{c40429d7c895981dff1d66d8be7720ef}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{9ef154b5f4836139850a1e1450aea2fe}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 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{8f8e0e7dab2545993a78a42af6720d23}, jobId:
cb3c57d0a3700c1e3b37ccf8453ebc4d).
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job cb3c57d0a3700c1e3b37ccf8453ebc4d from job leader monitoring.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job cb3c57d0a3700c1e3b37ccf8453ebc4d.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 8:18:50 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-f20d1d66-12fc-46c9-a74a-8933e4d49d1e
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:44845
Oct 26, 2018 8:18:50 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 26, 2018 8:18:50 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 6141 msecs
Oct 26, 2018 8:18:50 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 26, 2018 8:18:50 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@864fa9a7
2018-10-26T20:18:50.307Z Waiting for main pipeline to 'finish'
2018-10-26T20:18:50.308Z 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 27.442 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 22s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/zz6dumu7fcwhm
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]
