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

Changes:

[github] [BEAM-5886] Fix incorrectly formulated condition in checkState method

------------------------------------------
[...truncated 1.25 MB...]
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.056Z: Expanding CoGroupByKey operations into 
optimizable parts.
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.133Z: Expanding GroupByKey operations into 
optimizable parts.
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.176Z: Lifting ValueCombiningMappingFns into 
MergeBucketsMappingFns
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.308Z: Fusing adjacent ParDo, Read, Write, and Flatten 
operations
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.348Z: Unzipping flatten s17 for input 
s15.org.apache.beam.sdk.values.PCollection.<init>:402#c47715dbb819979d
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.394Z: Fusing unzipped copy of 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Reify, through 
flatten SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/Flatten, into 
producer SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/MakeUnionTable0
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.432Z: Fusing consumer 
SqlQuery3/SqlQuery3/Convert.ConvertTransform/ParDo(Anonymous) into 
SqlQuery3/SqlQuery3/SqlTransform/BeamCalcRel_359/ParDo(Calc)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.465Z: Fusing consumer SqlQuery3.Format into 
SqlQuery3/SqlQuery3.Stamp
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.492Z: Fusing consumer SqlQuery3.DevNull into 
SqlQuery3.Format
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.540Z: Fusing consumer SqlQuery3/SqlQuery3.Forget into 
SqlQuery3/SqlQuery3/Convert.ConvertTransform/ParDo(Anonymous)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.582Z: Fusing consumer SqlQuery3/SqlQuery3.Debug into 
SqlQuery3/SqlQuery3.Forget
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.627Z: Fusing consumer SqlQuery3/SqlQuery3.Stamp into 
SqlQuery3/SqlQuery3.Debug
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.673Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/ConstructCoGbkResultFn 
into SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/GroupByWindow
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.713Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/JoinParts2WholeRow/Map into 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/Join
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.757Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamCalcRel_359/ParDo(Calc) into 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/JoinParts2WholeRow/Map
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.805Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/Join into 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/ConstructCoGbkResultFn
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.849Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/GroupByWindow into 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Read
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.888Z: Unzipping flatten s17-u13 for input 
s18-reify-value0-c11
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.936Z: Fusing unzipped copy of 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Write, through 
flatten s17-u13, into producer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Reify
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:17.983Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlQuery3.Filter.Auction/ParDo(Anonymous) into 
SqlQuery3/SqlQuery3/Window.Into()/Window.Assign
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.021Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlQuery3.Filter.Person/ParDo(Anonymous) into 
SqlQuery3/SqlQuery3/Window.Into()/Window.Assign
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.057Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Reify into 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/MakeUnionTable1
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.102Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Write into 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Reify
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.142Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/MakeUnionTable0 into 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/left_ExtractJoinFields/Map
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.189Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlQuery3.ToRecords.Person/ParDo(Anonymous) into 
SqlQuery3/SqlQuery3/SqlQuery3.Filter.Person/ParDo(Anonymous)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.229Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamCalcRel_357/ParDo(Calc) into 
SqlQuery3/SqlQuery3/SqlTransform/BeamIOSourceRel_40/Convert.ConvertTransform/ParDo(Anonymous)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.277Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamCalcRel_356/ParDo(Calc) into 
SqlQuery3/SqlQuery3/SqlTransform/BeamIOSourceRel_34/Convert.ConvertTransform/ParDo(Anonymous)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.318Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/right_ExtractJoinFields/Map 
into SqlQuery3/SqlQuery3/SqlTransform/BeamCalcRel_357/ParDo(Calc)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.366Z: Fusing consumer SqlQuery3/SqlQuery3.Snoop into 
SqlQuery3/SqlQuery3.Monitor
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.403Z: Fusing consumer 
SqlQuery3/SqlQuery3/Window.Into()/Window.Assign into SqlQuery3/SqlQuery3.Snoop
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.454Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamIOSourceRel_40/Convert.ConvertTransform/ParDo(Anonymous)
 into SqlQuery3/SqlQuery3/SqlQuery3.ToRecords.Person/ParDo(Anonymous)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.500Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/MakeUnionTable1 into 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/right_ExtractJoinFields/Map
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.548Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamIOSourceRel_34/Convert.ConvertTransform/ParDo(Anonymous)
 into SqlQuery3/SqlQuery3/SqlQuery3.ToRecords.Auction/ParDo(Anonymous)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.598Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/left_ExtractJoinFields/Map 
into SqlQuery3/SqlQuery3/SqlTransform/BeamCalcRel_356/ParDo(Calc)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.640Z: Fusing consumer 
SqlQuery3/SqlQuery3/SqlQuery3.ToRecords.Auction/ParDo(Anonymous) into 
SqlQuery3/SqlQuery3/SqlQuery3.Filter.Auction/ParDo(Anonymous)
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:18.688Z: Fusing consumer SqlQuery3/SqlQuery3.Monitor 
into SqlQuery3.ReadBounded
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:19.171Z: Executing operation 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Create
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:19.277Z: Starting 4 workers in us-central1-b...
Oct 28, 2018 9:59:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:19.462Z: Executing operation 
SqlQuery3.ReadBounded+SqlQuery3/SqlQuery3.Monitor+SqlQuery3/SqlQuery3.Snoop+SqlQuery3/SqlQuery3/Window.Into()/Window.Assign+SqlQuery3/SqlQuery3/SqlQuery3.Filter.Auction/ParDo(Anonymous)+SqlQuery3/SqlQuery3/SqlQuery3.Filter.Person/ParDo(Anonymous)+SqlQuery3/SqlQuery3/SqlQuery3.ToRecords.Person/ParDo(Anonymous)+SqlQuery3/SqlQuery3/SqlTransform/BeamIOSourceRel_40/Convert.ConvertTransform/ParDo(Anonymous)+SqlQuery3/SqlQuery3/SqlTransform/BeamCalcRel_357/ParDo(Calc)+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/right_ExtractJoinFields/Map+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/MakeUnionTable1+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Reify+SqlQuery3/SqlQuery3/SqlQuery3.ToRecords.Auction/ParDo(Anonymous)+SqlQuery3/SqlQuery3/SqlTransform/BeamIOSourceRel_34/Convert.ConvertTransform/ParDo(Anonymous)+SqlQuery3/SqlQuery3/SqlTransform/BeamCalcRel_356/ParDo(Calc)+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/left_ExtractJoinFields/Map+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/MakeUnionTable0+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Reify+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Session/Flatten+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Write
Oct 28, 2018 9:59:29 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:29.089Z: Autoscaling: Raised the number of workers to 0 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 9:59:30 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:29.556Z: Autoscaling: Raised the number of workers to 0 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 9:59:30 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:30.086Z: Autoscaling: Raised the number of workers to 0 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 9:59:34 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T21:59:32.452Z: Autoscaling: Raised the number of workers to 0 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:04 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:03.774Z: Workers have started successfully.
Oct 28, 2018 10:00:04 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:03.685Z: Workers have started successfully.
Oct 28, 2018 10:00:04 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:03.616Z: Workers have started successfully.
Oct 28, 2018 10:00:06 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:03.570Z: Workers have started successfully.
Oct 28, 2018 10:00:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:23.194Z: Autoscaling: Raised the number of workers to 1 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:23 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:23.242Z: Resized worker pool to 1, though goal was 4.  
This could be a quota issue.
Oct 28, 2018 10:00:25 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:25.196Z: Autoscaling: Raised the number of workers to 1 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:25 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:25.243Z: Resized worker pool to 1, though goal was 4.  
This could be a quota issue.
Oct 28, 2018 10:00:26 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:25.304Z: Autoscaling: Raised the number of workers to 1 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:26 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:25.348Z: Resized worker pool to 1, though goal was 4.  
This could be a quota issue.
Oct 28, 2018 10:00:28 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:26.894Z: Autoscaling: Raised the number of workers to 1 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:28 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:26.937Z: Resized worker pool to 1, though goal was 4.  
This could be a quota issue.
Oct 28, 2018 10:00:31 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:30.888Z: Autoscaling: Raised the number of workers to 4 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:31 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:28.722Z: Autoscaling: Raised the number of workers to 3 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:31 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:28.768Z: Resized worker pool to 3, though goal was 4.  
This could be a quota issue.
Oct 28, 2018 10:00:31 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:30.688Z: Autoscaling: Raised the number of workers to 4 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:33 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:32.552Z: Autoscaling: Raised the number of workers to 4 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:34.715Z: Workers have started successfully.
Oct 28, 2018 10:00:35 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:34.830Z: Workers have started successfully.
Oct 28, 2018 10:00:36 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:34.917Z: Workers have started successfully.
Oct 28, 2018 10:00:36 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:34.975Z: Autoscaling: Raised the number of workers to 4 
based on the rate of progress in the currently running step(s).
Oct 28, 2018 10:00:36 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:00:35.076Z: Workers have started successfully.
Oct 28, 2018 10:01:00 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:01:00.467Z: Cleaning up.
Oct 28, 2018 10:01:00 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:01:00.586Z: Stopping worker pool...
Oct 28, 2018 10:01:28 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:01:28.563Z: Cleaning up.
Oct 28, 2018 10:01:28 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:01:28.694Z: Stopping worker pool...
Oct 28, 2018 10:01:34 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:01:33.503Z: Cleaning up.
Oct 28, 2018 10:01:34 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:01:33.615Z: Stopping worker pool...
Oct 28, 2018 10:02:01 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:02:01.522Z: Executing operation 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Close
Oct 28, 2018 10:02:01 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:02:01.616Z: Executing operation 
SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/Read+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/GBK/GroupByWindow+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/CoGBK/ConstructCoGbkResultFn+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/Join+SqlQuery3/SqlQuery3/SqlTransform/BeamJoinRel_358/JoinParts2WholeRow/Map+SqlQuery3/SqlQuery3/SqlTransform/BeamCalcRel_359/ParDo(Calc)+SqlQuery3/SqlQuery3/Convert.ConvertTransform/ParDo(Anonymous)+SqlQuery3/SqlQuery3.Forget+SqlQuery3/SqlQuery3.Debug+SqlQuery3/SqlQuery3.Stamp+SqlQuery3.Format+SqlQuery3.DevNull
Oct 28, 2018 10:02:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:02:06.344Z: Cleaning up.
Oct 28, 2018 10:02:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-10-28T22:02:06.461Z: Stopping worker pool...
Oct 28, 2018 10:03:10 PM org.apache.beam.runners.dataflow.DataflowPipelineJob 
waitUntilFinish
2018-10-28T22:03:10.713Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
Oct 28, 2018 10:03:10 PM org.apache.beam.runners.dataflow.DataflowPipelineJob 
waitUntilFinish
WARNING: No terminal state was returned. State value RUNNING
2018-10-28T22:03:10.715Z Waiting for main pipeline to 'finish'
2018-10-28T22:03:10.744Z RUNNING SqlQuery2
2018-10-28T22:03:10.766Z RUNNING SqlQuery1
Oct 28, 2018 10:03:10 PM org.apache.beam.runners.dataflow.DataflowPipelineJob 
waitUntilFinish
2018-10-28T22:03:10.810Z Waiting for main pipeline to 'finish'
WARNING: No terminal state was returned. State value RUNNING
2018-10-28T22:03:10.845Z RUNNING SqlQuery3
Oct 28, 2018 10:03:10 PM org.apache.beam.runners.dataflow.DataflowPipelineJob 
waitUntilFinish
WARNING: No terminal state was returned. State value RUNNING
2018-10-28T22:03:10.899Z Waiting for main pipeline to 'finish'
2018-10-28T22:03:10.942Z RUNNING SqlQuery0
2018-10-28T22:03:11.674Z new perf 
{"snapshots":null,"runtimeSec":43.917,"numEvents":10000000,"eventsPerSec":227702.2565293622,"eventBytesPerSec":2.9227062344877835E7,"numResults":83527,"resultsPerSec":1901.9286381128036,"resultBytesPerSec":30430.858209804857,"startupDelaySec":-174.373,"processingDelaySec":1.155,"shutdownDelaySec":130.456,"timeDilation":22.768859439397044,"errors":null,"jobId":null}
2018-10-28T22:03:11.813Z new perf 
{"snapshots":null,"runtimeSec":73.098,"numEvents":10000000,"eventsPerSec":136802.64849927495,"eventBytesPerSec":1.7559507743029904E7,"numResults":9200000,"resultsPerSec":125858.43661933295,"resultBytesPerSec":1.264869826807847E7,"startupDelaySec":-175.512,"processingDelaySec":0.715,"shutdownDelaySec":102.414,"timeDilation":13.679580836684998,"errors":null,"jobId":null}
2018-10-28T22:03:11.945Z new perf 
{"snapshots":null,"runtimeSec":76.89,"numEvents":10000000,"eventsPerSec":130055.92404734036,"eventBytesPerSec":1.6693521875406425E7,"numResults":9200000,"resultsPerSec":119651.45012355312,"resultBytesPerSec":1.2024899804916114E7,"startupDelaySec":-175.525,"processingDelaySec":0.726,"shutdownDelaySec":98.635,"timeDilation":13.0049421251138,"errors":null,"jobId":null}
2018-10-28T22:03:11.988Z new perf 
{"snapshots":null,"runtimeSec":48.892,"numEvents":10000000,"eventsPerSec":204532.43884480078,"eventBytesPerSec":2.625306587989855E7,"numResults":9054,"resultsPerSec":185.18367013008262,"resultBytesPerSec":5914.362267855681,"startupDelaySec":-113.62,"processingDelaySec":45.134,"shutdownDelaySec":64.728,"timeDilation":20.248711445635276,"errors":null,"jobId":null}
2018-10-28T22:03:26.715Z RUNNING SqlQuery2
2018-10-28T22:03:26.844Z RUNNING SqlQuery1
2018-10-28T22:03:26.984Z RUNNING SqlQuery0
2018-10-28T22:03:27.021Z RUNNING SqlQuery3
2018-10-28T22:03:27.480Z no activity
2018-10-28T22:03:27.621Z no activity
2018-10-28T22:03:27.736Z no activity
2018-10-28T22:03:27.834Z no activity
2018-10-28T22:03:42.513Z RUNNING SqlQuery2
2018-10-28T22:03:42.664Z RUNNING SqlQuery1
2018-10-28T22:03:42.792Z RUNNING SqlQuery0
2018-10-28T22:03:42.863Z RUNNING SqlQuery3
2018-10-28T22:03:43.206Z no activity
2018-10-28T22:03:43.486Z no activity
2018-10-28T22:03:43.493Z no activity
2018-10-28T22:03:43.684Z no activity
2018-10-28T22:03:58.235Z RUNNING SqlQuery2
2018-10-28T22:03:58.513Z RUNNING SqlQuery1
2018-10-28T22:03:58.526Z RUNNING SqlQuery0
2018-10-28T22:03:58.709Z RUNNING SqlQuery3
2018-10-28T22:03:58.966Z no activity
2018-10-28T22:03:59.227Z no activity
2018-10-28T22:03:59.227Z no activity
2018-10-28T22:03:59.517Z no activity
2018-10-28T22:04:14.004Z RUNNING SqlQuery2
2018-10-28T22:04:14.255Z RUNNING SqlQuery0
2018-10-28T22:04:14.255Z RUNNING SqlQuery1
2018-10-28T22:04:14.548Z RUNNING SqlQuery3
2018-10-28T22:04:14.791Z no activity
2018-10-28T22:04:14.991Z no activity
2018-10-28T22:04:15.037Z no activity
2018-10-28T22:04:15.308Z no activity
2018-10-28T22:04:29.821Z DONE SqlQuery2
2018-10-28T22:04:30.022Z RUNNING SqlQuery0
2018-10-28T22:04:30.072Z DONE SqlQuery1
2018-10-28T22:04:30.337Z RUNNING SqlQuery3
2018-10-28T22:04:30.758Z no activity
2018-10-28T22:04:31.115Z no activity
2018-10-28T22:04:45.797Z RUNNING SqlQuery0
2018-10-28T22:04:46.145Z RUNNING SqlQuery3
2018-10-28T22:04:46.534Z no activity
2018-10-28T22:04:47.137Z no activity
2018-10-28T22:05:01.562Z RUNNING SqlQuery0
2018-10-28T22:05:02.168Z RUNNING SqlQuery3
2018-10-28T22:05:02.270Z no activity
2018-10-28T22:05:02.999Z no activity
2018-10-28T22:05:17.307Z DONE SqlQuery0
2018-10-28T22:05:18.030Z RUNNING SqlQuery3
2018-10-28T22:05:18.862Z no activity
2018-10-28T22:05:33.888Z RUNNING SqlQuery3
2018-10-28T22:05:34.811Z no activity
2018-10-28T22:05:49.850Z DONE SqlQuery3

> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 6,5,main]) 
completed. Took 6 mins 48.099 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 7m 1s
68 actionable tasks: 2 executed, 66 up-to-date

Publishing build scan...
https://gradle.com/s/sgrsqxo5wmsja

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