See 
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/915/display/redirect?page=changes>

Changes:

[lukasz.gajowy] [BEAM-5716] Move nexmark to "testing" directory in java sdk

[lukasz.gajowy] [BEAM-5716] Move load-tests code to "testing" directory in java 
sdk

[lukasz.gajowy] [BEAM-5716] Create module for testing utils

[lukasz.gajowy] [BEAM-5716] Extract MetricReader class, test it and use in 
Nexmark code

[lukasz.gajowy] [BEAM-5355] Use MetricsReader in GroupByKeyLoadTest

------------------------------------------
[...truncated 22.88 MB...]
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16) (attempt 
#0) to localhost
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(8/16) (c13897299cec2e0ae65b4faff9da00e0) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for CHAIN MapPartition (MapPartition at 
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at 
Query12.DevNull/ParMultiDo(Anonymous).output) (15/16) 
(ff36b88fa2777ad89845fcf490fc8c95).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16) 
(c13897299cec2e0ae65b4faff9da00e0).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at 
Query12.DevNull/ParMultiDo(Anonymous).output) (15/16) 
(ff36b88fa2777ad89845fcf490fc8c95) [FINISHED]
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (8/16) 
(c13897299cec2e0ae65b4faff9da00e0) [FINISHED]
Oct 26, 2018 1:07:14 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) (10/16) 
(01eb7e2631620c29eac138851a4136bb) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 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) (10/16) 
(01eb7e2631620c29eac138851a4136bb).
Oct 26, 2018 1:07:14 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) (10/16) 
(01eb7e2631620c29eac138851a4136bb) [FINISHED]
Oct 26, 2018 1:07:14 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) (9/16) 
(b2ab9e6ddacb554839a3a88f659e6dbc) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
submitTask
INFO: Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(8/16) (c13897299cec2e0ae65b4faff9da00e0) switched from DEPLOYING to RUNNING.
Oct 26, 2018 1:07:14 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) ff36b88fa2777ad89845fcf490fc8c95.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(9/16) (ab2c7c07383ca2726bc3e406c2693ecb) switched from CREATED to DEPLOYING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(10/16) (3e19ea72f7558d8f4f551090aee7f9d8) switched from CREATED to SCHEDULED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16) 
(ab2c7c07383ca2726bc3e406c2693ecb) [DEPLOYING]
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(15/16) (563c9374655fb4fe2da624172edaa1eb) switched from CREATED to SCHEDULED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to 
JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
c13897299cec2e0ae65b4faff9da00e0.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16) 
(ab2c7c07383ca2726bc3e406c2693ecb) [DEPLOYING].
Oct 26, 2018 1:07:14 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) 01eb7e2631620c29eac138851a4136bb.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(10/16) (3e19ea72f7558d8f4f551090aee7f9d8) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(15/16) (563c9374655fb4fe2da624172edaa1eb) switched from SCHEDULED to DEPLOYING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16) (attempt 
#0) to localhost
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16) (attempt 
#0) to localhost
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: CHAIN MapPartition (MapPartition at 
Query12.DevNull/ParMultiDo(Anonymous)) -> FlatMap (FlatMap at 
Query12.DevNull/ParMultiDo(Anonymous).output) (15/16) 
(ff36b88fa2777ad89845fcf490fc8c95) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16) 
(ab2c7c07383ca2726bc3e406c2693ecb) [DEPLOYING].
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(8/16) (c13897299cec2e0ae65b4faff9da00e0) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(9/16) (ab2c7c07383ca2726bc3e406c2693ecb) switched from DEPLOYING to RUNNING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
submitTask
INFO: Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16).
Oct 26, 2018 1:07:14 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) (10/16) 
(01eb7e2631620c29eac138851a4136bb) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(10/16) (3e19ea72f7558d8f4f551090aee7f9d8) switched from CREATED to DEPLOYING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(9/16) (ab2c7c07383ca2726bc3e406c2693ecb) switched from DEPLOYING to RUNNING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16) 
(3e19ea72f7558d8f4f551090aee7f9d8) [DEPLOYING]
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16) 
(3e19ea72f7558d8f4f551090aee7f9d8) [DEPLOYING].
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
submitTask
INFO: Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(9/16) (ab2c7c07383ca2726bc3e406c2693ecb) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16) 
(ab2c7c07383ca2726bc3e406c2693ecb).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (9/16) 
(ab2c7c07383ca2726bc3e406c2693ecb) [FINISHED]
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16) 
(3e19ea72f7558d8f4f551090aee7f9d8) [DEPLOYING].
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to 
JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
ab2c7c07383ca2726bc3e406c2693ecb.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(15/16) (563c9374655fb4fe2da624172edaa1eb) switched from CREATED to DEPLOYING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(10/16) (3e19ea72f7558d8f4f551090aee7f9d8) switched from DEPLOYING to RUNNING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16) 
(563c9374655fb4fe2da624172edaa1eb) [DEPLOYING]
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16) 
(563c9374655fb4fe2da624172edaa1eb) [DEPLOYING].
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(9/16) (ab2c7c07383ca2726bc3e406c2693ecb) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16) 
(563c9374655fb4fe2da624172edaa1eb) [DEPLOYING].
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(10/16) (3e19ea72f7558d8f4f551090aee7f9d8) switched from DEPLOYING to RUNNING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(10/16) (3e19ea72f7558d8f4f551090aee7f9d8) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(15/16) (563c9374655fb4fe2da624172edaa1eb) switched from DEPLOYING to RUNNING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16) 
(3e19ea72f7558d8f4f551090aee7f9d8).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (10/16) 
(3e19ea72f7558d8f4f551090aee7f9d8) [FINISHED]
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(15/16) (563c9374655fb4fe2da624172edaa1eb) switched from DEPLOYING to RUNNING.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to 
JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
3e19ea72f7558d8f4f551090aee7f9d8.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(15/16) (563c9374655fb4fe2da624172edaa1eb) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16) 
(563c9374655fb4fe2da624172edaa1eb).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) (15/16) 
(563c9374655fb4fe2da624172edaa1eb) [FINISHED]
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(10/16) (3e19ea72f7558d8f4f551090aee7f9d8) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to 
JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
563c9374655fb4fe2da624172edaa1eb.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.Execution 
transitionState
INFO: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@a961a70) 
(15/16) (563c9374655fb4fe2da624172edaa1eb) switched from RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.executiongraph.ExecutionGraph 
transitionState
INFO: Job run-jenkins-1026130708-fe5bb6e2 (ae655fae4d6c0219885c90ea060571ae) 
switched from state RUNNING to FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.dispatcher.Dispatcher 
jobReachedGloballyTerminalState
INFO: Job ae655fae4d6c0219885c90ea060571ae reached globally terminal state 
FINISHED.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job 
run-jenkins-1026130708-fe5bb6e2(ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
closeJobManagerConnection
INFO: Close JobManager connection for job ae655fae4d6c0219885c90ea060571ae.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.jobmaster.JobMaster 
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 3699eabba351b8781c1b96c28cb3cb2b: 
JobManager is shutting down..
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool 
suspend
INFO: Suspending SlotPool.
Oct 26, 2018 1:07:14 PM 
org.apache.flink.runtime.resourcemanager.ResourceManager 
closeJobManagerConnection
INFO: Disconnect job manager 
b4b6ddb7a541ae1a1f4833966a6948f5@akka://flink/user/jobmanager_25 for job 
ae655fae4d6c0219885c90ea060571ae from the resource manager.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool 
postStop
INFO: Stopping SlotPool.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.minicluster.MiniCluster 
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.rest.RestServerEndpoint 
closeAsync
INFO: Shutting down rest endpoint.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher 
akka://flink/user/dispatcherf9ef2129-3578-4210-9e81-88c1ff212292.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.dispatcher.Dispatcher 
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher 
akka://flink/user/dispatcherf9ef2129-3578-4210-9e81-88c1ff212292.
Oct 26, 2018 1:07:14 PM 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 26, 2018 1:07:14 PM 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 26, 2018 1:07:14 PM 
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl 
jobManagerLostLeadership
INFO: JobManager for job ae655fae4d6c0219885c90ea060571ae with leader id 
b4b6ddb7a541ae1a1f4833966a6948f5 lost leadership.
Oct 26, 2018 1:07:14 PM 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager 
unregisterTaskManager
INFO: Unregister TaskManager 8d50f0fc613b34374e94e7d30c837a34 from the 
SlotManager.
Oct 26, 2018 1:07:14 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{b022219aae9f4cdd4122103bf5b3ba07}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{743d8864aa0d6bdc91ffee9a232c7036}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{a6bb2a5bd7bf58b53f71aa37ebc94a9e}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{c958ab25fcfd7ac12c21c94be7f8dc57}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{299dfcebed0fc7050bc91594dcc974f2}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{a525c18b73ae7815ee2c84a375160e09}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{e9bda0b41679afbc5896bc3f6731a702}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 PM 
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
 shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.dispatcher.Dispatcher 
lambda$postStop$0
INFO: Stopped dispatcher 
akka://flink/user/dispatcherf9ef2129-3578-4210-9e81-88c1ff212292.
Oct 26, 2018 1:07:14 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{c9ce8fca6f7e20e8706d5e6e4aa3eb0c}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint 
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 26, 2018 1:07:14 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{2a4f4a5cd9aa3a62c79d601e58561c39}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{e3f9645de2abf5761ac1325cf1da519c}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{0ea5a8b1167330692d37a69e0e7a8ffa}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{d6e72f5844ce893f593fffd22a08ce55}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{afd8df1d734c3bfac3a98bfc8a930fc8}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{931cf66f7b82d6aaf15183c0d4a8092b}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{ff35eab750aa7c2d7d45cd91cc99c260}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 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{268fcb15278fac0ea75f88d24c71aad2}, jobId: 
ae655fae4d6c0219885c90ea060571ae).
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.JobLeaderService 
removeJob
INFO: Remove job ae655fae4d6c0219885c90ea060571ae from job leader monitoring.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
closeJobManagerConnection
INFO: Close JobManager connection for job ae655fae4d6c0219885c90ea060571ae.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 1:07:14 PM 
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.io.disk.iomanager.IOManager 
shutdown
INFO: I/O manager removed spill file directory 
/tmp/flink-io-0deb2abd-5eca-4445-94ab-c78b87874cd7
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.io.network.NetworkEnvironment 
shutdown
INFO: Shutting down the network environment and its components.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.JobLeaderService 
stop
INFO: Stop job leader service.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.taskexecutor.TaskExecutor 
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
stopService
INFO: Stopping Akka RPC service.
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:36539
Oct 26, 2018 1:07:14 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService 
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 26, 2018 1:07:14 PM org.apache.beam.runners.flink.FlinkRunner 
createPipelineResult
INFO: Execution finished in 5722 msecs
Oct 26, 2018 1:07:14 PM org.apache.beam.runners.flink.FlinkRunner 
createPipelineResult
INFO: Final accumulator values:
Oct 26, 2018 1:07:14 PM org.apache.beam.runners.flink.FlinkRunner 
createPipelineResult
INFO: __metricscontainers : 
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@864fa9a7
2018-10-26T13:07:14.809Z Waiting for main pipeline to 'finish'
2018-10-26T13:07:14.809Z DONE Query12

> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':',5,main]) completed. 
Took 1 mins 26.511 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/rwjfo7lpofvgq

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

Reply via email to