See 
<https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow_V2_Java11/1072/display/redirect?page=changes>

Changes:

[Pablo Estrada] Simplify README for new users

[laraschmidt] Fix final allowskew error to properly handle a large allowedSkew

[noreply] [BEAM-13946] Add get_dummies(), a non-deferred column operation on


------------------------------------------
[...truncated 156.27 KB...]
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.372Z: Fusing adjacent ParDo, Read, Write, and Flatten 
operations
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.400Z: Fusing consumer 
Query11.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource) 
into Query11.ReadBounded/Impulse
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.434Z: Fusing consumer 
Query11-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction
 into 
Query11.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.466Z: Fusing consumer 
Query11-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
 into 
Query11-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.502Z: Fusing consumer 
Query11/Query11.Monitor/ParMultiDo(Monitor) into 
Query11-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.522Z: Fusing consumer 
Query11/Query11.Snoop/ParMultiDo(Anonymous) into 
Query11/Query11.Monitor/ParMultiDo(Monitor)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.557Z: Fusing consumer 
Query11/Query11/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) into 
Query11/Query11.Snoop/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.590Z: Fusing consumer 
Query11/Query11/justBids/AsBid/ParMultiDo(Anonymous) into 
Query11/Query11/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.611Z: Fusing consumer 
Query11/Query11/Query11.Rekey/ParMultiDo(Anonymous) into 
Query11/Query11/justBids/AsBid/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.643Z: Fusing consumer 
Query11/Query11/Window.Into()/Window.Assign into 
Query11/Query11/Query11.Rekey/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.664Z: Fusing consumer 
Query11/Query11/Count.PerElement/Init/Map/ParMultiDo(Anonymous) into 
Query11/Query11/Window.Into()/Window.Assign
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.688Z: Fusing consumer 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/AddInput
 into Query11/Query11/Count.PerElement/Init/Map/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.711Z: Fusing consumer 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify into 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/AddInput
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.747Z: Fusing consumer 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Write into 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.782Z: Fusing consumer 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/GroupByWindow 
into Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.829Z: Fusing consumer 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues 
into 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/GroupByWindow
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.854Z: Fusing consumer 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract
 into 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.882Z: Fusing consumer 
Query11/Query11/Query11.ToResult/ParMultiDo(Anonymous) into 
Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.916Z: Fusing consumer 
Query11/Query11.Debug/ParMultiDo(Monitor) into 
Query11/Query11/Query11.ToResult/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.947Z: Fusing consumer 
Query11/Query11.Stamp/ParMultiDo(Anonymous) into 
Query11/Query11.Debug/ParMultiDo(Monitor)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.986Z: Fusing consumer 
Query11.Format/ParMultiDo(Anonymous) into 
Query11/Query11.Stamp/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.037Z: Fusing consumer 
Query11.DevNull/ParMultiDo(Anonymous) into Query11.Format/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.404Z: Executing operation 
Query11.ReadBounded/Impulse+Query11.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query11-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query11-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
Feb 18, 2022 12:26:02 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.486Z: Starting 4 ****s in us-central1-a...
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:00.513Z: Executing operation 
Query1.ReadBounded/Impulse+Query1.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query1-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query1-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:00.583Z: Starting 4 ****s in us-central1-b...
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:00.630Z: Fusing consumer 
Query0/Query0.Stamp/ParMultiDo(Anonymous) into 
Query0/Query0.Debug/ParMultiDo(Monitor)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:00.662Z: Fusing consumer 
Query0.Format/ParMultiDo(Anonymous) into 
Query0/Query0.Stamp/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:00.693Z: Fusing consumer 
Query0.DevNull/ParMultiDo(Anonymous) into Query0.Format/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.122Z: Executing operation 
Query0.ReadBounded/Impulse+Query0.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query0-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query0-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.200Z: Starting 4 ****s in us-central1-c...
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.952Z: Fusing consumer 
Query14-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
 into 
Query14-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.987Z: Fusing consumer 
Query14/Query14.Monitor/ParMultiDo(Monitor) into 
Query14-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.020Z: Fusing consumer 
Query14/Query14.Snoop/ParMultiDo(Anonymous) into 
Query14/Query14.Monitor/ParMultiDo(Monitor)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.061Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Pair with random 
key/ParMultiDo(AssignShard) into Query14/Query14.Snoop/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.094Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign 
into Query14/Query14/Reshuffle.ViaRandomKey/Pair with random 
key/ParMultiDo(AssignShard)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.129Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 into 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.160Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify into 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.190Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write into 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.220Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow into 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.257Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 into Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.278Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 into 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.312Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 into 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.337Z: Fusing consumer 
Query14/Query14/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous) 
into 
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.373Z: Fusing consumer 
Query14/Query14.Debug/ParMultiDo(Monitor) into 
Query14/Query14/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.413Z: Fusing consumer 
Query14/Query14.Stamp/ParMultiDo(Anonymous) into 
Query14/Query14.Debug/ParMultiDo(Monitor)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.434Z: Fusing consumer 
Query14.Format/ParMultiDo(Anonymous) into 
Query14/Query14.Stamp/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.491Z: Fusing consumer 
Query14.DevNull/ParMultiDo(Anonymous) into Query14.Format/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.888Z: Executing operation 
Query14.ReadBounded/Impulse+Query14.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query14-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query14-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
Feb 18, 2022 12:26:03 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.978Z: Starting 4 ****s in us-central1-a...
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.914Z: Expanding SplittableParDo operations into 
optimizable parts.
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:01.956Z: Expanding CollectionToSingleton operations into 
optimizable parts.
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.023Z: Expanding CoGroupByKey operations into 
optimizable parts.
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.197Z: Expanding GroupByKey operations into 
optimizable parts.
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.291Z: Fusing adjacent ParDo, Read, Write, and Flatten 
operations
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.327Z: Unzipping flatten 
Query5-Query5-Combine-globally-Top--Combine-perKeyWithFanout-Top--Flatten-PCollections
 for input 
Query5-Query5-Combine-globally-Top--Combine-perKeyWithFanout-Top--PrepareCold-Map-ParMultiDo-Anonymo.output
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.372Z: Fusing unzipped copy of 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Partial,
 through flatten 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/Flatten.PCollections,
 into producer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PrepareCold/Map/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.407Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Write
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Reify
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.437Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/GroupByWindow
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Read
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.459Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/GroupByWindow
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.494Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Extract
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.536Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Values/Values/Map/ParMultiDo(Anonymous) 
into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Extract
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.578Z: Fusing consumer 
Query5/Query5/Query5.Select/ParMultiDo(Anonymous) into 
Query5/Query5/Combine.globally(Top)/Values/Values/Map/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.599Z: Fusing consumer 
Query5/Query5.Debug/ParMultiDo(Monitor) into 
Query5/Query5/Query5.Select/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.632Z: Fusing consumer 
Query5/Query5.Stamp/ParMultiDo(Anonymous) into 
Query5/Query5.Debug/ParMultiDo(Monitor)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.671Z: Fusing consumer 
Query5.Format/ParMultiDo(Anonymous) into 
Query5/Query5.Stamp/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.716Z: Fusing consumer 
Query5.DevNull/ParMultiDo(Anonymous) into Query5.Format/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.755Z: Unzipping flatten 
Query5-Query5-Combine-globally-Top--Combine-perKeyWithFanout-Top--Flatten-PCollections-u64
 for input 
partial-Query5-Query5-Combine-globally-Top--Combine-perKeyWithFanout-Top--PostCombine-GroupByKey-out7-c62
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.774Z: Fusing unzipped copy of 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Reify,
 through flatten 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/Flatten.PCollections/Unzipped-1,
 into producer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Partial
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.819Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Partial
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/Window.Remerge/Identity/Map/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.858Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Reify
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Partial
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.886Z: Fusing consumer 
Query5.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource) 
into Query5.ReadBounded/Impulse
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.921Z: Fusing consumer 
Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction
 into 
Query5.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.956Z: Fusing consumer 
Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
 into 
Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:02.988Z: Fusing consumer 
Query5/Query5.Monitor/ParMultiDo(Monitor) into 
Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.025Z: Fusing consumer 
Query5/Query5.Snoop/ParMultiDo(Anonymous) into 
Query5/Query5.Monitor/ParMultiDo(Monitor)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.048Z: Fusing consumer 
Query5/Query5/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) into 
Query5/Query5.Snoop/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.083Z: Fusing consumer 
Query5/Query5/justBids/AsBid/ParMultiDo(Anonymous) into 
Query5/Query5/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.122Z: Fusing consumer 
Query5/Query5/Window.Into()/Window.Assign into 
Query5/Query5/justBids/AsBid/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.147Z: Fusing consumer 
Query5/Query5/BidToAuction/ParMultiDo(Anonymous) into 
Query5/Query5/Window.Into()/Window.Assign
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.178Z: Fusing consumer 
Query5/Query5/Count.PerElement/Init/Map/ParMultiDo(Anonymous) into 
Query5/Query5/BidToAuction/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.204Z: Fusing consumer 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey+Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Partial
 into Query5/Query5/Count.PerElement/Init/Map/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.236Z: Fusing consumer 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify into 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey+Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Partial
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.284Z: Fusing consumer 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Write into 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.314Z: Fusing consumer 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/GroupByWindow 
into Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.344Z: Fusing consumer 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues into 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/GroupByWindow
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.392Z: Fusing consumer 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract
 into Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.425Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) 
into 
Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.465Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/AddNonce into 
Query5/Query5/Combine.globally(Top)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.495Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PrepareCold/Map/ParMultiDo(Anonymous)
 into Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/AddNonce
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.523Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues/Partial
 into Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/AddNonce
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.557Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Reify
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues/Partial
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.588Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Write
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Reify
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.616Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/GroupByWindow
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Read
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.651Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/GroupByWindow
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.697Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues/Extract
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.719Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/StripNonce/Map/ParMultiDo(Anonymous)
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues/Extract
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.746Z: Fusing consumer 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/Window.Remerge/Identity/Map/ParMultiDo(Anonymous)
 into 
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/StripNonce/Map/ParMultiDo(Anonymous)
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:04.141Z: Executing operation 
Query5.ReadBounded/Impulse+Query5.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:04.214Z: Starting 4 ****s in us-central1-b...
Feb 18, 2022 12:26:04 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:03.340Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
Feb 18, 2022 12:26:05 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:05.124Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
Feb 18, 2022 12:26:06 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:04.742Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
Feb 18, 2022 12:26:10 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:10.586Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
Feb 18, 2022 12:26:11 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:11.300Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
Feb 18, 2022 12:26:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:10.794Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
Feb 18, 2022 12:26:26 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:23.657Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
Feb 18, 2022 12:26:26 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-18T00:26:26.218Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-5' is disconnected.
        at 
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:216)
        at 
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:286)
        at com.sun.proxy.$Proxy126.isAlive(Unknown Source)
        at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1213)
        at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1205)
        at hudson.Launcher$ProcStarter.join(Launcher.java:522)
        at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
        at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:806)
        at hudson.model.Build$BuildExecution.build(Build.java:198)
        at hudson.model.Build$BuildExecution.doRun(Build.java:163)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:514)
        at hudson.model.Run.execute(Run.java:1888)
        at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
        at hudson.model.ResourceController.execute(ResourceController.java:99)
        at hudson.model.Executor.run(Executor.java:432)
Caused by: java.io.IOException: Unexpected termination of the channel
        at 
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:75)
Caused by: java.io.EOFException
        at 
java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2799)
        at 
java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:3274)
        at 
java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:934)
        at java.io.ObjectInputStream.<init>(ObjectInputStream.java:396)
        at 
hudson.remoting.ObjectInputStreamEx.<init>(ObjectInputStreamEx.java:49)
        at hudson.remoting.Command.readFrom(Command.java:142)
        at hudson.remoting.Command.readFrom(Command.java:128)
        at 
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:35)
        at 
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-5 is offline; cannot locate jdk_1.8_latest


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to