See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/927/display/redirect?page=changes>
Changes:
[amaliujia] Test NULL in Pubsub JSON format for SQL read.
------------------------------------------
[...truncated 22.88 MB...]
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(14/16) (4973f77cdd69290ffae7957fd8c47da8) switched from CREATED to SCHEDULED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (9/16)
(7a3efa69c61078f032a27c20d3aaf35c) [DEPLOYING].
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (2/16).
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(9/16) (7a3efa69c61078f032a27c20d3aaf35c) switched from DEPLOYING to RUNNING.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(14/16) (4973f77cdd69290ffae7957fd8c47da8) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(9/16) (7a3efa69c61078f032a27c20d3aaf35c) switched from DEPLOYING to RUNNING.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (14/16) (attempt
#0) to localhost
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(2/16) (598141c7377576e9acb5f5071d7216ed) switched from CREATED to DEPLOYING.
Oct 27, 2018 3:16:26 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@6ce3815f)
67b63526599eab0f47068e15b2ed6d94.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(9/16) (7a3efa69c61078f032a27c20d3aaf35c) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 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@6ce3815f) (2/16)
(598141c7377576e9acb5f5071d7216ed) [DEPLOYING]
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (9/16)
(7a3efa69c61078f032a27c20d3aaf35c).
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (2/16)
(598141c7377576e9acb5f5071d7216ed) [DEPLOYING].
Oct 27, 2018 3:16:26 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@6ce3815f) (9/16)
(7a3efa69c61078f032a27c20d3aaf35c) [FINISHED]
Oct 27, 2018 3:16:26 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) 7eebcd446dc0690c31751b87c24a2763.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(3/16) (67b63526599eab0f47068e15b2ed6d94) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (2/16)
(598141c7377576e9acb5f5071d7216ed) [DEPLOYING].
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(2/16) (598141c7377576e9acb5f5071d7216ed) switched from DEPLOYING to RUNNING.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(2/16) (598141c7377576e9acb5f5071d7216ed) switched from DEPLOYING to RUNNING.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(2/16) (598141c7377576e9acb5f5071d7216ed) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (2/16)
(598141c7377576e9acb5f5071d7216ed).
Oct 27, 2018 3:16:26 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@6ce3815f) (2/16)
(598141c7377576e9acb5f5071d7216ed) [FINISHED]
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (14/16).
Oct 27, 2018 3:16:26 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) (14/16)
(7eebcd446dc0690c31751b87c24a2763) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 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@6ce3815f)
7a3efa69c61078f032a27c20d3aaf35c.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(14/16) (4973f77cdd69290ffae7957fd8c47da8) switched from CREATED to DEPLOYING.
Oct 27, 2018 3:16:26 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@6ce3815f) (14/16)
(4973f77cdd69290ffae7957fd8c47da8) [DEPLOYING]
Oct 27, 2018 3:16:26 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) (16/16)
(ac6b6db169b99bd0378bbf6870047c60) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 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@6ce3815f)
598141c7377576e9acb5f5071d7216ed.
Oct 27, 2018 3:16:26 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) (16/16)
(ac6b6db169b99bd0378bbf6870047c60).
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (14/16)
(4973f77cdd69290ffae7957fd8c47da8) [DEPLOYING].
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(16/16) (e2b2d1332c42a395680bfa086cecddb6) switched from CREATED to SCHEDULED.
Oct 27, 2018 3:16:26 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) (16/16)
(ac6b6db169b99bd0378bbf6870047c60) [FINISHED]
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(9/16) (7a3efa69c61078f032a27c20d3aaf35c) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 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) ac6b6db169b99bd0378bbf6870047c60.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(16/16) (e2b2d1332c42a395680bfa086cecddb6) switched from SCHEDULED to DEPLOYING.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (14/16)
(4973f77cdd69290ffae7957fd8c47da8) [DEPLOYING].
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(2/16) (598141c7377576e9acb5f5071d7216ed) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (16/16) (attempt
#0) to localhost
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(14/16) (4973f77cdd69290ffae7957fd8c47da8) switched from DEPLOYING to RUNNING.
Oct 27, 2018 3:16:26 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) (16/16)
(ac6b6db169b99bd0378bbf6870047c60) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (16/16).
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(14/16) (4973f77cdd69290ffae7957fd8c47da8) switched from DEPLOYING to RUNNING.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(14/16) (4973f77cdd69290ffae7957fd8c47da8) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (14/16)
(4973f77cdd69290ffae7957fd8c47da8).
Oct 27, 2018 3:16:26 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@6ce3815f) (14/16)
(4973f77cdd69290ffae7957fd8c47da8) [FINISHED]
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(16/16) (e2b2d1332c42a395680bfa086cecddb6) switched from CREATED to DEPLOYING.
Oct 27, 2018 3:16:26 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@6ce3815f) (16/16)
(e2b2d1332c42a395680bfa086cecddb6) [DEPLOYING]
Oct 27, 2018 3:16:26 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@6ce3815f)
4973f77cdd69290ffae7957fd8c47da8.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (16/16)
(e2b2d1332c42a395680bfa086cecddb6) [DEPLOYING].
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(14/16) (4973f77cdd69290ffae7957fd8c47da8) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (16/16)
(e2b2d1332c42a395680bfa086cecddb6) [DEPLOYING].
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(16/16) (e2b2d1332c42a395680bfa086cecddb6) switched from DEPLOYING to RUNNING.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(16/16) (e2b2d1332c42a395680bfa086cecddb6) switched from DEPLOYING to RUNNING.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(16/16) (e2b2d1332c42a395680bfa086cecddb6) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f) (16/16)
(e2b2d1332c42a395680bfa086cecddb6).
Oct 27, 2018 3:16:26 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@6ce3815f) (16/16)
(e2b2d1332c42a395680bfa086cecddb6) [FINISHED]
Oct 27, 2018 3:16:26 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@6ce3815f)
e2b2d1332c42a395680bfa086cecddb6.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ce3815f)
(16/16) (e2b2d1332c42a395680bfa086cecddb6) switched from RUNNING to FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027031620-454f0d99 (bfc040b527c40d9cdf73828a6a729583)
switched from state RUNNING to FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job bfc040b527c40d9cdf73828a6a729583 reached globally terminal state
FINISHED.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027031620-454f0d99(bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job bfc040b527c40d9cdf73828a6a729583.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 18074d73ff047d429d9389b8178b137d:
JobManager is shutting down..
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 3:16:26 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
a66488415967a84b0f6cf3da73064616@akka://flink/user/jobmanager_25 for job
bfc040b527c40d9cdf73828a6a729583 from the resource manager.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 3:16:26 AM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job bfc040b527c40d9cdf73828a6a729583 with leader id
a66488415967a84b0f6cf3da73064616 lost leadership.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher19f11eba-8f77-46e2-99bb-d3e62aff6e6f.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher19f11eba-8f77-46e2-99bb-d3e62aff6e6f.
Oct 27, 2018 3:16:26 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 3:16:26 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 3:16:26 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{e7c40c6841207f0d4403c750f83925ce}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 AM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 4afccf4d8458008317949c495ba0bd6d from the
SlotManager.
Oct 27, 2018 3:16:26 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{73518ff98e1092d99bc9c5a487b7a70d}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{ce3109183313a166a8023bcc6f5f0777}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{b1318ab7fd09b78293bf8e819142697b}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{db5542093cefe637d5df2c334150652c}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{ed906598017311f89d3aa88003c628d1}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{b41b04afbf7c740aa854cde68fdbd72e}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{e167f7f26ce72eeb14a5ba60868c83f3}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{544df9b39dcc6848e40c4eabe7dd293d}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{7cf8f96de2c831ea216326801245a903}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{235a548cd8fbe9763a1007936445ea00}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{7e0571842cb57feecc9b75b8cb63ca66}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{3345fdd9db42d00bc021080c440efbbf}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{72a3e9a122a4cd753b966b31380a8944}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{322e717d212a47fdfe48facbe6253610}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 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{da49b568adc95aa3d2771069301678f5}, jobId:
bfc040b527c40d9cdf73828a6a729583).
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job bfc040b527c40d9cdf73828a6a729583 from job leader monitoring.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job bfc040b527c40d9cdf73828a6a729583.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 3:16:26 AM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 3:16:26 AM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-f6d2cae9-d8c8-4265-ba1b-da5397a0d459
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher19f11eba-8f77-46e2-99bb-d3e62aff6e6f.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:39623
Oct 27, 2018 3:16:26 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 3:16:26 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 5953 msecs
Oct 27, 2018 3:16:26 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 3:16:26 AM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@949b94e7
2018-10-27T03:16:26.877Z Waiting for main pipeline to 'finish'
2018-10-27T03:16:26.877Z DONE Query12
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 2,5,main])
completed. Took 1 mins 26.867 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 17s
68 actionable tasks: 64 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/ng5kil6cxrfxg
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]
