See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/929/display/redirect?page=changes>
Changes:
[relax] Switch SQL over to use the new Beam Group transform.
------------------------------------------
[...truncated 22.87 MB...]
Oct 27, 2018 5:49:42 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@a961a70) (4/16)
(ccd15b471101c1ddca6cf942671db943) [DEPLOYING]
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(ccd15b471101c1ddca6cf942671db943) [DEPLOYING].
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(ccd15b471101c1ddca6cf942671db943) [DEPLOYING].
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16).
Oct 27, 2018 5:49:42 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) (4/16)
(53782f015bb9c21dbe027ab1afdb50cf) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (ccd15b471101c1ddca6cf942671db943) switched from DEPLOYING to RUNNING.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(10/16) (0fc98bb1962095cda85c8afaa193a7ac) switched from CREATED to DEPLOYING.
Oct 27, 2018 5:49:42 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) f737de6e23372232f03efbea4a44c9fc.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (ccd15b471101c1ddca6cf942671db943) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (ccd15b471101c1ddca6cf942671db943) switched from DEPLOYING to RUNNING.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (4/16)
(ccd15b471101c1ddca6cf942671db943).
Oct 27, 2018 5:49:42 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@a961a70) (10/16)
(0fc98bb1962095cda85c8afaa193a7ac) [DEPLOYING]
Oct 27, 2018 5:49:42 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@a961a70) (4/16)
(ccd15b471101c1ddca6cf942671db943) [FINISHED]
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16)
(0fc98bb1962095cda85c8afaa193a7ac) [DEPLOYING].
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16)
(0fc98bb1962095cda85c8afaa193a7ac) [DEPLOYING].
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(10/16) (0fc98bb1962095cda85c8afaa193a7ac) switched from DEPLOYING to RUNNING.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN MapPartition (MapPartition at
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at
Query12.DevNull/ParMultiDo(Anonymous).output) (3/16)
(4f679b8bfdbda617c1c590c5ce2d0fea) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM 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) (3/16)
(4f679b8bfdbda617c1c590c5ce2d0fea).
Oct 27, 2018 5:49:42 AM 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) (3/16)
(4f679b8bfdbda617c1c590c5ce2d0fea) [FINISHED]
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (6/16).
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(10/16) (0fc98bb1962095cda85c8afaa193a7ac) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 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) (6/16)
(f737de6e23372232f03efbea4a44c9fc) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16)
(0fc98bb1962095cda85c8afaa193a7ac).
Oct 27, 2018 5:49:42 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@a961a70) (10/16)
(0fc98bb1962095cda85c8afaa193a7ac) [FINISHED]
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (10237443155b8b755f370971cc0b7f00) switched from CREATED to DEPLOYING.
Oct 27, 2018 5:49:42 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@a961a70)
c1b682892a9d51cf572ad5d99f0a9ad2.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(3/16) (b789646876141d8f348d3a6f752a5271) switched from CREATED to SCHEDULED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(10/16) (0fc98bb1962095cda85c8afaa193a7ac) switched from DEPLOYING to RUNNING.
Oct 27, 2018 5:49:42 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@a961a70)
ccd15b471101c1ddca6cf942671db943.
Oct 27, 2018 5:49:42 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@a961a70) (6/16)
(10237443155b8b755f370971cc0b7f00) [DEPLOYING]
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(3/16) (b789646876141d8f348d3a6f752a5271) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 5:49:42 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) 4f679b8bfdbda617c1c590c5ce2d0fea.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(7/16) (c1b682892a9d51cf572ad5d99f0a9ad2) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (3/16) (attempt
#0) to localhost
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (6/16)
(10237443155b8b755f370971cc0b7f00) [DEPLOYING].
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(4/16) (ccd15b471101c1ddca6cf942671db943) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 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@a961a70)
0fc98bb1962095cda85c8afaa193a7ac.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (6/16)
(10237443155b8b755f370971cc0b7f00) [DEPLOYING].
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (10237443155b8b755f370971cc0b7f00) switched from DEPLOYING to RUNNING.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (3/16).
Oct 27, 2018 5:49:42 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) (3/16)
(4f679b8bfdbda617c1c590c5ce2d0fea) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(3/16) (b789646876141d8f348d3a6f752a5271) switched from CREATED to DEPLOYING.
Oct 27, 2018 5:49:42 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@a961a70) (3/16)
(b789646876141d8f348d3a6f752a5271) [DEPLOYING]
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (10237443155b8b755f370971cc0b7f00) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(10/16) (0fc98bb1962095cda85c8afaa193a7ac) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (3/16)
(b789646876141d8f348d3a6f752a5271) [DEPLOYING].
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (6/16)
(10237443155b8b755f370971cc0b7f00).
Oct 27, 2018 5:49:42 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@a961a70) (6/16)
(10237443155b8b755f370971cc0b7f00) [FINISHED]
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (10237443155b8b755f370971cc0b7f00) switched from DEPLOYING to RUNNING.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (3/16)
(b789646876141d8f348d3a6f752a5271) [DEPLOYING].
Oct 27, 2018 5:49:42 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@a961a70)
10237443155b8b755f370971cc0b7f00.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(3/16) (b789646876141d8f348d3a6f752a5271) switched from DEPLOYING to RUNNING.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(6/16) (10237443155b8b755f370971cc0b7f00) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(3/16) (b789646876141d8f348d3a6f752a5271) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (3/16)
(b789646876141d8f348d3a6f752a5271).
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(3/16) (b789646876141d8f348d3a6f752a5271) switched from DEPLOYING to RUNNING.
Oct 27, 2018 5:49:42 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@a961a70) (3/16)
(b789646876141d8f348d3a6f752a5271) [FINISHED]
Oct 27, 2018 5:49:42 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@a961a70)
b789646876141d8f348d3a6f752a5271.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70)
(3/16) (b789646876141d8f348d3a6f752a5271) switched from RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027054936-7f27e25f (48fd352e474ba22d24f561d3895c77ba)
switched from state RUNNING to FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job 48fd352e474ba22d24f561d3895c77ba reached globally terminal state
FINISHED.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027054936-7f27e25f(48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 48fd352e474ba22d24f561d3895c77ba.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection c182fd9f18b66e0cd8a83a5822020fe1:
JobManager is shutting down..
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 5:49:42 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
a93fec514fe5d40fb9b2a0adcd6745b9@akka://flink/user/jobmanager_25 for job
48fd352e474ba22d24f561d3895c77ba from the resource manager.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher1089a0b6-a46c-470a-ba1c-2b4699c5151e.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher1089a0b6-a46c-470a-ba1c-2b4699c5151e.
Oct 27, 2018 5:49:42 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job 48fd352e474ba22d24f561d3895c77ba with leader id
a93fec514fe5d40fb9b2a0adcd6745b9 lost leadership.
Oct 27, 2018 5:49:42 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 5:49:42 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 5:49:42 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 5a4f426777793daf908530a515f926b6 from the
SlotManager.
Oct 27, 2018 5:49:42 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{01d650575fad959911a99780b9467edf}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{77f41ff6e1d2e21caf9f68939505c6dd}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{7a326d8809e82b25868ea7d4f8de9c6c}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{46963ed8528b79242eb5058692036932}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher1089a0b6-a46c-470a-ba1c-2b4699c5151e.
Oct 27, 2018 5:49:42 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{4d166fd01341bf64e830978082e98117}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{5ca74093fc580d9f8ece57ba7797582b}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{f331c7923fa9ef5ad803cfe5e62bcfbc}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{f0f4178e5f264618566facb68828514f}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{fefac8e004bc72fb627a607fa1d97854}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{de2de8538b9d37499f99bf42770412ca}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{e19ed9d6889eb90cefc780dd902d3771}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{8e4d99e1de39b9e3f1803060e5bb00cf}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{8a1685ce4bd6bab2a1bb7cce23d01625}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{6420945d513f53631e625d0091a710b6}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{baa1a2069d5c8eec77b4e8655ed25290}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 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{84970ef5c23f45b3e5355118bfa6bd7d}, jobId:
48fd352e474ba22d24f561d3895c77ba).
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job 48fd352e474ba22d24f561d3895c77ba from job leader monitoring.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job 48fd352e474ba22d24f561d3895c77ba.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 5:49:42 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-701f53f2-b721-4614-87fa-ef597ab01864
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:37579
Oct 27, 2018 5:49:42 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 5:49:42 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5536 msecs
Oct 27, 2018 5:49:42 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 5:49:42 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@864fa9a7
2018-10-27T05:49:42.969Z Waiting for main pipeline to 'finish'
2018-10-27T05:49:42.969Z 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 28.221 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/xe2zil4cr3ise
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]
