See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/922/display/redirect?page=changes>
Changes:
[scott] Replace precommit dashboard image with an actual image
------------------------------------------
[...truncated 22.88 MB...]
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (9/16)
(4473a6f164167c7e38791f318a6cd810) [DEPLOYING].
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (7/16).
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (747f16b63969efd47b50547d93ee53c4) switched from CREATED to SCHEDULED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (9/16)
(4473a6f164167c7e38791f318a6cd810) [DEPLOYING].
Oct 26, 2018 8:32:12 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) d927d5e00d1bf1356bd6f4285d543477.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(9/16) (4473a6f164167c7e38791f318a6cd810) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (747f16b63969efd47b50547d93ee53c4) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(7/16) (38b09479052fc17791c1387f18dec5b1) switched from CREATED to DEPLOYING.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(9/16) (4473a6f164167c7e38791f318a6cd810) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:32:12 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@3aef037d) (7/16)
(38b09479052fc17791c1387f18dec5b1) [DEPLOYING]
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(9/16) (4473a6f164167c7e38791f318a6cd810) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (1/16) (attempt
#0) to localhost
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (9/16)
(4473a6f164167c7e38791f318a6cd810).
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (7/16)
(38b09479052fc17791c1387f18dec5b1) [DEPLOYING].
Oct 26, 2018 8:32:12 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) (14/16)
(44af7b6d869987db5073b60cbd9568aa) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(14/16) (2115d45431a6da7e720e34ab7362137b) switched from CREATED to SCHEDULED.
Oct 26, 2018 8:32:12 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@3aef037d) (9/16)
(4473a6f164167c7e38791f318a6cd810) [FINISHED]
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (7/16)
(38b09479052fc17791c1387f18dec5b1) [DEPLOYING].
Oct 26, 2018 8:32:12 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)
(d927d5e00d1bf1356bd6f4285d543477) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 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) (14/16)
(44af7b6d869987db5073b60cbd9568aa).
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(14/16) (2115d45431a6da7e720e34ab7362137b) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(7/16) (38b09479052fc17791c1387f18dec5b1) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (14/16) (attempt
#0) to localhost
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (1/16).
Oct 26, 2018 8:32:12 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) (14/16)
(44af7b6d869987db5073b60cbd9568aa) [FINISHED]
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(7/16) (38b09479052fc17791c1387f18dec5b1) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:32:12 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@3aef037d)
4473a6f164167c7e38791f318a6cd810.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (747f16b63969efd47b50547d93ee53c4) switched from CREATED to DEPLOYING.
Oct 26, 2018 8:32:12 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@3aef037d) (1/16)
(747f16b63969efd47b50547d93ee53c4) [DEPLOYING]
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (1/16)
(747f16b63969efd47b50547d93ee53c4) [DEPLOYING].
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(7/16) (38b09479052fc17791c1387f18dec5b1) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 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) 44af7b6d869987db5073b60cbd9568aa.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (7/16)
(38b09479052fc17791c1387f18dec5b1).
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (1/16)
(747f16b63969efd47b50547d93ee53c4) [DEPLOYING].
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(9/16) (4473a6f164167c7e38791f318a6cd810) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 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@3aef037d) (7/16)
(38b09479052fc17791c1387f18dec5b1) [FINISHED]
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (747f16b63969efd47b50547d93ee53c4) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (747f16b63969efd47b50547d93ee53c4) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (1/16)
(747f16b63969efd47b50547d93ee53c4).
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (14/16).
Oct 26, 2018 8:32:12 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@3aef037d) (1/16)
(747f16b63969efd47b50547d93ee53c4) [FINISHED]
Oct 26, 2018 8:32:12 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@3aef037d)
38b09479052fc17791c1387f18dec5b1.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(14/16) (2115d45431a6da7e720e34ab7362137b) switched from CREATED to DEPLOYING.
Oct 26, 2018 8:32:12 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) (14/16)
(44af7b6d869987db5073b60cbd9568aa) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 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@3aef037d)
747f16b63969efd47b50547d93ee53c4.
Oct 26, 2018 8:32:12 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@3aef037d) (14/16)
(2115d45431a6da7e720e34ab7362137b) [DEPLOYING]
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (747f16b63969efd47b50547d93ee53c4) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (14/16)
(2115d45431a6da7e720e34ab7362137b) [DEPLOYING].
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(7/16) (38b09479052fc17791c1387f18dec5b1) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (14/16)
(2115d45431a6da7e720e34ab7362137b) [DEPLOYING].
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(1/16) (747f16b63969efd47b50547d93ee53c4) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(14/16) (2115d45431a6da7e720e34ab7362137b) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(14/16) (2115d45431a6da7e720e34ab7362137b) switched from DEPLOYING to RUNNING.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(14/16) (2115d45431a6da7e720e34ab7362137b) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d) (14/16)
(2115d45431a6da7e720e34ab7362137b).
Oct 26, 2018 8:32:12 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@3aef037d) (14/16)
(2115d45431a6da7e720e34ab7362137b) [FINISHED]
Oct 26, 2018 8:32:12 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@3aef037d)
2115d45431a6da7e720e34ab7362137b.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3aef037d)
(14/16) (2115d45431a6da7e720e34ab7362137b) switched from RUNNING to FINISHED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1026203205-fb55ff5a (ce414590872c7753cfc48b3aa64492e5)
switched from state RUNNING to FINISHED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job ce414590872c7753cfc48b3aa64492e5 reached globally terminal state
FINISHED.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1026203205-fb55ff5a(ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job ce414590872c7753cfc48b3aa64492e5.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 2cbe9e95eb870ee99d2d17c326defca0:
JobManager is shutting down..
Oct 26, 2018 8:32:12 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
a46459baddf9a92ed8ac7dd2f3ba4735@akka://flink/user/jobmanager_25 for job
ce414590872c7753cfc48b3aa64492e5 from the resource manager.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.rpc.akka.AkkaRpcActor onReceive
INFO: The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has
not been started yet. Discarding message
org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is
started.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher2465c135-a8d7-4960-a135-8060c1252329.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher2465c135-a8d7-4960-a135-8060c1252329.
Oct 26, 2018 8:32:12 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 26, 2018 8:32:12 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 26, 2018 8:32:12 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager e869df160e5e3c5192ac239a325030e5 from the
SlotManager.
Oct 26, 2018 8:32:12 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job ce414590872c7753cfc48b3aa64492e5 with leader id
a46459baddf9a92ed8ac7dd2f3ba4735 lost leadership.
Oct 26, 2018 8:32:12 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{26fa8e2a7523d31a4359a4c45fd1796c}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{104a3ab89ca05f54096b5a2ceab7f7ae}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{f6ad3d483cc73819bdf169fa66fe2327}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{7676a1ae910e766f4b349573aedebb79}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{b73ee8a201e60d57ab77928401ab4372}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{dce90cdc97a21b55465491a8bb603d1a}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{f65765cf2cb43bd0e9e21bfd1b089aa1}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{f5f1b6b8124ce128eb6b77a996b1b78e}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{c6a1a5dcec6b76498c1677052a9ba0ea}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{059e88ab1ddc95aded63880767203446}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{e82db2fb5f8046ab30b3e5ea684a16ad}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 26, 2018 8:32:12 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{88ace4e30489af19b732a15f4028253a}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher2465c135-a8d7-4960-a135-8060c1252329.
Oct 26, 2018 8:32:12 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{963dc5bb511fe65da91f4d3cd25f489c}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{0fcd7f1fc0e9747fc0080113d4babb3c}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{00245b60b08107efd0cb0c81fbd1ac5d}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 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{b806d5de7c4011ea949f857c53fabbad}, jobId:
ce414590872c7753cfc48b3aa64492e5).
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job ce414590872c7753cfc48b3aa64492e5 from job leader monitoring.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job ce414590872c7753cfc48b3aa64492e5.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 8:32:12 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-bd5bace5-f889-4f5d-90a6-9caf7dd94143
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:41859
Oct 26, 2018 8:32:12 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 26, 2018 8:32:12 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 6172 msecs
Oct 26, 2018 8:32:12 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 26, 2018 8:32:12 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@89352230
2018-10-26T20:32:12.262Z Waiting for main pipeline to 'finish'
2018-10-26T20:32:12.262Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 11,5,main])
completed. Took 1 mins 27.793 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/7xcukt5w7wsgy
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org
