See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/924/display/redirect?page=changes>
Changes:
[ccy] Support multiple versions of snappy for tfrecordio
------------------------------------------
[...truncated 22.95 MB...]
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (11/16)
(0ee9031e1ad0ecbb4606398d41412f4d) [DEPLOYING].
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16).
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (11/16)
(0ee9031e1ad0ecbb4606398d41412f4d) [DEPLOYING].
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (9/16)
(7919dca1a233de672528f43ce7f4e3a9) [DEPLOYING].
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (57e036ebdce1579a553bcce4e5f42852) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(9/16) (7919dca1a233de672528f43ce7f4e3a9) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(11/16) (0ee9031e1ad0ecbb4606398d41412f4d) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM 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) 54b47177b61463696840c45955ad070d.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16)
(57e036ebdce1579a553bcce4e5f42852) [DEPLOYING]
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(9/16) (7919dca1a233de672528f43ce7f4e3a9) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16)
(57e036ebdce1579a553bcce4e5f42852) [DEPLOYING].
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(11/16) (0ee9031e1ad0ecbb4606398d41412f4d) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16)
(57e036ebdce1579a553bcce4e5f42852) [DEPLOYING].
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (57e036ebdce1579a553bcce4e5f42852) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (15/16).
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (12/16)
(54b47177b61463696840c45955ad070d) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(11/16) (0ee9031e1ad0ecbb4606398d41412f4d) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(9/16) (7919dca1a233de672528f43ce7f4e3a9) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM 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) aba1c7becef243064ef2375618f7446e.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (9/16)
(7919dca1a233de672528f43ce7f4e3a9).
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (57e036ebdce1579a553bcce4e5f42852) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM 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) (9/16)
(7919dca1a233de672528f43ce7f4e3a9) [FINISHED]
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(15/16) (bb16c247c6eebfcf60323867a524d992) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (57e036ebdce1579a553bcce4e5f42852) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (11/16)
(0ee9031e1ad0ecbb4606398d41412f4d).
Oct 27, 2018 12:29:12 AM 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) (15/16)
(bb16c247c6eebfcf60323867a524d992) [DEPLOYING]
Oct 27, 2018 12:29:12 AM 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) (11/16)
(0ee9031e1ad0ecbb4606398d41412f4d) [FINISHED]
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (15/16)
(bb16c247c6eebfcf60323867a524d992) [DEPLOYING].
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16)
(57e036ebdce1579a553bcce4e5f42852).
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (12/16)
(57e036ebdce1579a553bcce4e5f42852) [FINISHED]
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (15/16)
(bb16c247c6eebfcf60323867a524d992) [DEPLOYING].
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (1/16).
Oct 27, 2018 12:29:12 AM 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)
(aba1c7becef243064ef2375618f7446e) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(15/16) (bb16c247c6eebfcf60323867a524d992) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM 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) df4a3d45e36d7e88b756ce8064e78931.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(15/16) (bb16c247c6eebfcf60323867a524d992) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(1/16) (ce9951646fbb31722d03919cb3cfb6ac) switched from CREATED to DEPLOYING.
Oct 27, 2018 12:29:12 AM 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) (1/16)
(ce9951646fbb31722d03919cb3cfb6ac) [DEPLOYING]
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (1/16)
(ce9951646fbb31722d03919cb3cfb6ac) [DEPLOYING].
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(15/16) (bb16c247c6eebfcf60323867a524d992) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (15/16)
(bb16c247c6eebfcf60323867a524d992).
Oct 27, 2018 12:29:12 AM 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) (15/16)
(bb16c247c6eebfcf60323867a524d992) [FINISHED]
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (1/16)
(ce9951646fbb31722d03919cb3cfb6ac) [DEPLOYING].
Oct 27, 2018 12:29:12 AM 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)
7919dca1a233de672528f43ce7f4e3a9.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(1/16) (ce9951646fbb31722d03919cb3cfb6ac) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM 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)
0ee9031e1ad0ecbb4606398d41412f4d.
Oct 27, 2018 12:29:12 AM 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)
(df4a3d45e36d7e88b756ce8064e78931) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM 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)
57e036ebdce1579a553bcce4e5f42852.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(1/16) (ce9951646fbb31722d03919cb3cfb6ac) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM 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)
bb16c247c6eebfcf60323867a524d992.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964) (1/16)
(ce9951646fbb31722d03919cb3cfb6ac).
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(9/16) (7919dca1a233de672528f43ce7f4e3a9) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM 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) (1/16)
(ce9951646fbb31722d03919cb3cfb6ac) [FINISHED]
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(1/16) (ce9951646fbb31722d03919cb3cfb6ac) switched from DEPLOYING to RUNNING.
Oct 27, 2018 12:29:12 AM 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)
ce9951646fbb31722d03919cb3cfb6ac.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(11/16) (0ee9031e1ad0ecbb4606398d41412f4d) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(12/16) (57e036ebdce1579a553bcce4e5f42852) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(15/16) (bb16c247c6eebfcf60323867a524d992) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@153cf964)
(1/16) (ce9951646fbb31722d03919cb3cfb6ac) switched from RUNNING to FINISHED.
Oct 27, 2018 12:29:12 AM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027002906-c481ff8b (c5d9246de49f4629c1dbf79511f70bea)
switched from state RUNNING to FINISHED.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job c5d9246de49f4629c1dbf79511f70bea reached globally terminal state
FINISHED.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027002906-c481ff8b(c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job c5d9246de49f4629c1dbf79511f70bea.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 1d83f14f2b176ee7fae87caae214f9d4:
JobManager is shutting down..
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 12:29:13 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
95a28b40930956a5fb4263d3addd4b24@akka://flink/user/jobmanager_25 for job
c5d9246de49f4629c1dbf79511f70bea from the resource manager.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher3317d831-ebb6-4fef-b909-47b1c638a93d.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher3317d831-ebb6-4fef-b909-47b1c638a93d.
Oct 27, 2018 12:29:13 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job c5d9246de49f4629c1dbf79511f70bea with leader id
95a28b40930956a5fb4263d3addd4b24 lost leadership.
Oct 27, 2018 12:29:13 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 12:29:13 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 12:29:13 AM
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{13995f0c6f3b4c06bf55a7d0840b0e32}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager b354ff3b6cde0ca9702217904a3c8f2e from the
SlotManager.
Oct 27, 2018 12:29:13 AM
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{143edd76f100641850f06d089dac91c3}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{954aa5b4616794fbe10c46791b354318}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{65b29a14621c6daa52601b2c6ad8ffdd}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{a9fd7d3dbb9b58dff24475c28dca49f9}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{db06287c13fc48263982198cf09e75a1}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{999c69d0d7841a3915556a4dd84ac21d}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{2e4049441d0747e01e40b5435dc7414e}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{0bbf9e9f934c2f4441e6a27dbd40fe98}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{2ccb3c9e5529aaf2ccf03fb7817ee576}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{10522cb1cbd368e5713e082fd1ea45b1}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{d4fe6df2d77f08c53702e462918e433f}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{83d6a98196824f32247b307962a5ec19}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{1d231913120a465de41e451efdd8d9a5}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
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{186bc64549a656d7d88ed975a983b1ea}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 12:29:13 AM
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{25254e4843d18a2db13dd542d9252ef4}, jobId:
c5d9246de49f4629c1dbf79511f70bea).
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher3317d831-ebb6-4fef-b909-47b1c638a93d.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job c5d9246de49f4629c1dbf79511f70bea from job leader monitoring.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job c5d9246de49f4629c1dbf79511f70bea.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 12:29:13 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-55d073f6-e822-44b6-a138-e2a16ea3aae2
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:46333
Oct 27, 2018 12:29:13 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 12:29:13 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 6083 msecs
Oct 27, 2018 12:29:13 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 12:29:13 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@9eff92a9
2018-10-27T00:29:13.031Z Waiting for main pipeline to 'finish'
2018-10-27T00:29:13.031Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':',5,main]) completed.
Took 1 mins 27.632 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 20s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/6nlogmlzkljek
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]
