See
<https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow_V2_Java17/2031/display/redirect>
Changes:
------------------------------------------
[...truncated 215.11 KB...]
May 14, 2023 9:38:51 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:38:49.798Z: Executing operation
Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create
May 14, 2023 9:38:51 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:38:50.269Z: Finished operation
Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create
May 14, 2023 9:38:51 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:38:50.366Z: Executing operation
Query12-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query12/Query12.Monitor/ParMultiDo(Monitor)+Query12/Query12.Snoop/ParMultiDo(Anonymous)+Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous)+Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query12/Query12/Window.Into()/Window.Assign+Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous)+Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey+Query12/Query12/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Partial+Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Write
May 14, 2023 9:38:52 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:38:49.644Z: Workers have started successfully.
May 14, 2023 9:39:00 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:38:59.562Z: Finished operation
Query2-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query2/Query2.Monitor/ParMultiDo(Monitor)+Query2/Query2.Snoop/ParMultiDo(Anonymous)+Query2/Query2/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query2/Query2/justBids/AsBid/ParMultiDo(Anonymous)+Query2/Query2/Filter/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query2/Query2/Query2.Project/ParMultiDo(Anonymous)+Query2/Query2.Debug/ParMultiDo(Monitor)+Query2/Query2.Stamp/ParMultiDo(Anonymous)+Query2.Format/ParMultiDo(Anonymous)+Query2.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:00 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:38:59.659Z: Cleaning up.
May 14, 2023 9:39:00 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:38:59.724Z: Stopping **** pool...
May 14, 2023 9:39:01 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:38:59.686Z: All ****s have finished the startup processes
and began to receive work requests.
May 14, 2023 9:39:01 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:01.155Z: All ****s have finished the startup processes
and began to receive work requests.
May 14, 2023 9:39:03 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:01.883Z: Finished operation
Query5.ReadBounded/Impulse+Query5.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
May 14, 2023 9:39:03 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:02.016Z: Executing operation
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create
May 14, 2023 9:39:03 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:02.626Z: Finished operation
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create
May 14, 2023 9:39:03 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:02.763Z: Executing operation
Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query5/Query5.Monitor/ParMultiDo(Monitor)+Query5/Query5.Snoop/ParMultiDo(Anonymous)+Query5/Query5/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query5/Query5/justBids/AsBid/ParMultiDo(Anonymous)+Query5/Query5/Window.Into()/Window.Assign+Query5/Query5/BidToAuction/ParMultiDo(Anonymous)+Query5/Query5/Count.PerElement/Init/Map/ParMultiDo(Anonymous)+Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey+Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Partial+Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify+Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Write
May 14, 2023 9:39:03 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:02.910Z: Finished operation
Query11-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query11/Query11.Monitor/ParMultiDo(Monitor)+Query11/Query11.Snoop/ParMultiDo(Anonymous)+Query11/Query11/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query11/Query11/justBids/AsBid/ParMultiDo(Anonymous)+Query11/Query11/Query11.Rekey/ParMultiDo(Anonymous)+Query11/Query11/Window.Into()/Window.Assign+Query11/Query11/Count.PerElement/Init/Map/ParMultiDo(Anonymous)+Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/AddInput+Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify+Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Write
May 14, 2023 9:39:03 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:02.954Z: Executing operation
Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
May 14, 2023 9:39:03 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:02.986Z: Finished operation
Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
May 14, 2023 9:39:03 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:03.032Z: Executing operation
Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/GroupByWindow+Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+Query11/Query11/Query11.ToResult/ParMultiDo(Anonymous)+Query11/Query11.Debug/ParMultiDo(Monitor)+Query11/Query11.Stamp/ParMultiDo(Anonymous)+Query11.Format/ParMultiDo(Anonymous)+Query11.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:05 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:04.324Z: Finished operation
Query10.ReadBounded/Impulse+Query10.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query10-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query10-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing
May 14, 2023 9:39:05 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:04.443Z: Executing operation
Query10/Query10/Query10.GroupByKey/Create
May 14, 2023 9:39:05 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:04.887Z: Finished operation
Query10/Query10/Query10.GroupByKey/Create
May 14, 2023 9:39:05 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.006Z: Executing operation
Query10-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query10/Query10.Monitor/ParMultiDo(Monitor)+Query10/Query10.Snoop/ParMultiDo(Anonymous)+Query10/Query10/Query10.ShardEvents/ParMultiDo(Anonymous)+Query10/Query10/Query10.WindowEvents/Window.Assign+Query10/Query10/Query10.GroupByKey/Reify+Query10/Query10/Query10.GroupByKey/Write
May 14, 2023 9:39:05 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.470Z: Finished operation
Query14-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query14/Query14.Monitor/ParMultiDo(Monitor)+Query14/Query14.Snoop/ParMultiDo(Anonymous)+Query14/Query14/Reshuffle.ViaRandomKey/Pair
with random
key/ParMultiDo(AssignShard)+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
May 14, 2023 9:39:05 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.533Z: Executing operation
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
May 14, 2023 9:39:05 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.578Z: Finished operation
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
May 14, 2023 9:39:05 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.637Z: Executing operation
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query14/Query14/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)+Query14/Query14.Debug/ParMultiDo(Monitor)+Query14/Query14.Stamp/ParMultiDo(Anonymous)+Query14.Format/ParMultiDo(Anonymous)+Query14.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:06 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.149Z: Finished operation
Query1-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query1/Query1.Monitor/ParMultiDo(Monitor)+Query1/Query1.Snoop/ParMultiDo(Anonymous)+Query1/Query1/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query1/Query1/justBids/AsBid/ParMultiDo(Anonymous)+Query1/Query1/Query1.ToEuros/ParMultiDo(Anonymous)+Query1/Query1.Debug/ParMultiDo(Monitor)+Query1/Query1.Stamp/ParMultiDo(Anonymous)+Query1.Format/ParMultiDo(Anonymous)+Query1.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:06 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.258Z: Cleaning up.
May 14, 2023 9:39:06 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.314Z: Stopping **** pool...
May 14, 2023 9:39:07 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.287Z: Finished operation
Query12-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query12/Query12.Monitor/ParMultiDo(Monitor)+Query12/Query12.Snoop/ParMultiDo(Anonymous)+Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous)+Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query12/Query12/Window.Into()/Window.Assign+Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous)+Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey+Query12/Query12/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Partial+Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Write
May 14, 2023 9:39:07 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.350Z: Executing operation
Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
May 14, 2023 9:39:07 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.453Z: Finished operation
Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
May 14, 2023 9:39:07 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:05.513Z: Executing operation
Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+Query12/Query12/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+Query12/Query12/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+Query12/Query12/Query12.ToResult/ParMultiDo(Anonymous)+Query12/Query12.Debug/ParMultiDo(Monitor)+Query12/Query12.Stamp/ParMultiDo(Anonymous)+Query12.Format/ParMultiDo(Anonymous)+Query12.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:07 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:07.629Z: Finished operation
Query0-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query0/Query0.Monitor/ParMultiDo(Monitor)+Query0/Query0.Snoop/ParMultiDo(Anonymous)+Query0/Query0/Query0.Serialize/ParMultiDo(Anonymous)+Query0/Query0.Debug/ParMultiDo(Monitor)+Query0/Query0.Stamp/ParMultiDo(Anonymous)+Query0.Format/ParMultiDo(Anonymous)+Query0.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:07 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:07.705Z: Cleaning up.
May 14, 2023 9:39:07 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:07.757Z: Stopping **** pool...
May 14, 2023 9:39:10 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:08.725Z: Finished operation
Query13-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query13/Query13.Monitor/ParMultiDo(Monitor)+Query13/Query13.Snoop/ParMultiDo(Anonymous)+Query13/Query13/Pair
with random key/ParMultiDo(AssignShard)+Query13/Query13/GroupByKey/Write
May 14, 2023 9:39:10 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:08.775Z: Executing operation
Query13/Query13/GroupByKey/Close
May 14, 2023 9:39:10 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:08.864Z: Finished operation
Query13/Query13/GroupByKey/Close
May 14, 2023 9:39:10 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:08.925Z: Executing operation
Query13/Query13/GroupByKey/Read+Query13/Query13/ExpandIterable/ParMultiDo(Anonymous)+Query13/Query13/Query13.Serialize/ParMultiDo(Anonymous)+Query13/Query13.Debug/ParMultiDo(Monitor)+Query13/Query13.Stamp/ParMultiDo(Anonymous)+Query13.Format/ParMultiDo(Anonymous)+Query13.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:10.069Z: Finished operation
Query8-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query8/Query8.Monitor/ParMultiDo(Monitor)+Query8/Query8.Snoop/ParMultiDo(Anonymous)+Query8/Query8/justNewAuctions/IsNewAuction/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query8/Query8/justNewPersons/IsNewPerson/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query8/Query8/justNewPersons/AsPerson/ParMultiDo(Anonymous)+Query8/Query8/Query8.WindowPersons/Window.Assign+Query8/Query8/PersonById/ParMultiDo(Anonymous)+Query8/Query8/CoGroupByKey/MakeUnionTable0/ParMultiDo(ConstructUnionTable)+Query8/Query8/CoGroupByKey/GBK/Reify+Query8/Query8/justNewAuctions/AsAuction/ParMultiDo(Anonymous)+Query8/Query8/Query8.WindowAuctions/Window.Assign+Query8/Query8/AuctionBySeller/ParMultiDo(Anonymous)+Query8/Query8/CoGroupByKey/MakeUnionTable1/ParMultiDo(ConstructUnionTable)+Query8/Query8/CoGroupByKey/GBK/Reify+Query8/Query8/CoGroupByKey/GBK/Session/Flatten+Query8/Query8/CoGroupByKey/GBK/Write
May 14, 2023 9:39:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:10.130Z: Executing operation
Query8/Query8/CoGroupByKey/GBK/Close
May 14, 2023 9:39:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:10.180Z: Finished operation
Query8/Query8/CoGroupByKey/GBK/Close
May 14, 2023 9:39:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:10.240Z: Executing operation
Query8/Query8/CoGroupByKey/GBK/Read+Query8/Query8/CoGroupByKey/GBK/GroupByWindow+Query8/Query8/CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult)+Query8/Query8/Query8.Select/ParMultiDo(Anonymous)+Query8/Query8.Debug/ParMultiDo(Monitor)+Query8/Query8.Stamp/ParMultiDo(Anonymous)+Query8.Format/ParMultiDo(Anonymous)+Query8.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:10.192Z: Finished operation
Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/GroupByWindow+Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+Query11/Query11/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+Query11/Query11/Query11.ToResult/ParMultiDo(Anonymous)+Query11/Query11.Debug/ParMultiDo(Monitor)+Query11/Query11.Stamp/ParMultiDo(Anonymous)+Query11.Format/ParMultiDo(Anonymous)+Query11.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:10.328Z: Cleaning up.
May 14, 2023 9:39:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:10.397Z: Stopping **** pool...
May 14, 2023 9:39:12 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:11.915Z: Finished operation
Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+Query12/Query12/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+Query12/Query12/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+Query12/Query12/Query12.ToResult/ParMultiDo(Anonymous)+Query12/Query12.Debug/ParMultiDo(Monitor)+Query12/Query12.Stamp/ParMultiDo(Anonymous)+Query12.Format/ParMultiDo(Anonymous)+Query12.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:12 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:12.057Z: Cleaning up.
May 14, 2023 9:39:12 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:12.129Z: Stopping **** pool...
May 14, 2023 9:39:14 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:13.026Z: Finished operation
Query8/Query8/CoGroupByKey/GBK/Read+Query8/Query8/CoGroupByKey/GBK/GroupByWindow+Query8/Query8/CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult)+Query8/Query8/Query8.Select/ParMultiDo(Anonymous)+Query8/Query8.Debug/ParMultiDo(Monitor)+Query8/Query8.Stamp/ParMultiDo(Anonymous)+Query8.Format/ParMultiDo(Anonymous)+Query8.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:14 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:13.154Z: Cleaning up.
May 14, 2023 9:39:14 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:13.216Z: Stopping **** pool...
May 14, 2023 9:39:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:22.042Z: Finished operation
Query5-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query5/Query5.Monitor/ParMultiDo(Monitor)+Query5/Query5.Snoop/ParMultiDo(Anonymous)+Query5/Query5/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query5/Query5/justBids/AsBid/ParMultiDo(Anonymous)+Query5/Query5/Window.Into()/Window.Assign+Query5/Query5/BidToAuction/ParMultiDo(Anonymous)+Query5/Query5/Count.PerElement/Init/Map/ParMultiDo(Anonymous)+Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey+Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Partial+Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify+Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Write
May 14, 2023 9:39:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:22.109Z: Executing operation
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
May 14, 2023 9:39:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:22.167Z: Finished operation
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
May 14, 2023 9:39:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:22.226Z: Executing operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Create
May 14, 2023 9:39:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:22.413Z: Finished operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Create
May 14, 2023 9:39:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:22.540Z: Executing operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Create
May 14, 2023 9:39:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:22.681Z: Finished operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Create
May 14, 2023 9:39:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:22.828Z: Executing operation
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/GroupByWindow+Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+Query5/Query5/Combine.globally(Top)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/AddNonce+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PrepareCold/Map/ParMultiDo(Anonymous)+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Partial+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Reify+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Write+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues/Partial+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Reify+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Write
May 14, 2023 9:39:25 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:24.944Z: Finished operation
Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query14/Query14/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)+Query14/Query14/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)+Query14/Query14.Debug/ParMultiDo(Monitor)+Query14/Query14.Stamp/ParMultiDo(Anonymous)+Query14.Format/ParMultiDo(Anonymous)+Query14.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:26 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:25.143Z: Cleaning up.
May 14, 2023 9:39:26 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:25.221Z: Stopping **** pool...
May 14, 2023 9:39:27 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:27.495Z: Finished operation
Query13/Query13/GroupByKey/Read+Query13/Query13/ExpandIterable/ParMultiDo(Anonymous)+Query13/Query13/Query13.Serialize/ParMultiDo(Anonymous)+Query13/Query13.Debug/ParMultiDo(Monitor)+Query13/Query13.Stamp/ParMultiDo(Anonymous)+Query13.Format/ParMultiDo(Anonymous)+Query13.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:27 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:27.614Z: Cleaning up.
May 14, 2023 9:39:27 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:27.692Z: Stopping **** pool...
May 14, 2023 9:39:33 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:32.750Z: Finished operation
Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/GroupByWindow+Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+Query5/Query5/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+Query5/Query5/Combine.globally(Top)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/AddNonce+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PrepareCold/Map/ParMultiDo(Anonymous)+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Partial+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Reify+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Write+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues/Partial+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Reify+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Write
May 14, 2023 9:39:33 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:32.806Z: Executing operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Close
May 14, 2023 9:39:33 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:32.867Z: Finished operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Close
May 14, 2023 9:39:33 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:32.955Z: Executing operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Read+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/GroupByWindow+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues/Extract+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/StripNonce/Map/ParMultiDo(Anonymous)+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/Window.Remerge/Identity/Map/ParMultiDo(Anonymous)+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Partial+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Reify+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Write
May 14, 2023 9:39:33 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:33.421Z: Finished operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Read+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/GroupByWindow+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/Combine.GroupedValues/Extract+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/StripNonce/Map/ParMultiDo(Anonymous)+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/Window.Remerge/Identity/Map/ParMultiDo(Anonymous)+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Partial+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Reify+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Write
May 14, 2023 9:39:33 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:33.489Z: Executing operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Close
May 14, 2023 9:39:35 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:34.424Z: Finished operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Close
May 14, 2023 9:39:35 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:34.489Z: Executing operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Read+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/GroupByWindow+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Extract+Query5/Query5/Combine.globally(Top)/Values/Values/Map/ParMultiDo(Anonymous)+Query5/Query5/Query5.Select/ParMultiDo(Anonymous)+Query5/Query5.Debug/ParMultiDo(Monitor)+Query5/Query5.Stamp/ParMultiDo(Anonymous)+Query5.Format/ParMultiDo(Anonymous)+Query5.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:35 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:34.952Z: Finished operation
Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Read+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/GroupByWindow+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues+Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/Combine.GroupedValues/Extract+Query5/Query5/Combine.globally(Top)/Values/Values/Map/ParMultiDo(Anonymous)+Query5/Query5/Query5.Select/ParMultiDo(Anonymous)+Query5/Query5.Debug/ParMultiDo(Monitor)+Query5/Query5.Stamp/ParMultiDo(Anonymous)+Query5.Format/ParMultiDo(Anonymous)+Query5.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:35 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:35.114Z: Cleaning up.
May 14, 2023 9:39:35 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:35.193Z: Stopping **** pool...
May 14, 2023 9:39:41 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:39.763Z: Finished operation
Query10-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/ProcessElementAndRestrictionWithSizing+Query10/Query10.Monitor/ParMultiDo(Monitor)+Query10/Query10.Snoop/ParMultiDo(Anonymous)+Query10/Query10/Query10.ShardEvents/ParMultiDo(Anonymous)+Query10/Query10/Query10.WindowEvents/Window.Assign+Query10/Query10/Query10.GroupByKey/Reify+Query10/Query10/Query10.GroupByKey/Write
May 14, 2023 9:39:41 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:39.828Z: Executing operation
Query10/Query10/Query10.GroupByKey/Close
May 14, 2023 9:39:41 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:39.880Z: Finished operation
Query10/Query10/Query10.GroupByKey/Close
May 14, 2023 9:39:41 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:39.944Z: Executing operation
Query10/Query10/Query10.GroupByKey2/Create
May 14, 2023 9:39:41 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:40.082Z: Finished operation
Query10/Query10/Query10.GroupByKey2/Create
May 14, 2023 9:39:41 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:40.222Z: Executing operation
Query10/Query10/Query10.GroupByKey/Read+Query10/Query10/Query10.GroupByKey/GroupByWindow+Query10/Query10/Query10.CheckForLateEvents/ParMultiDo(Anonymous)+Query10/Query10/Query10.UploadEvents/ParMultiDo(Anonymous)+Query10/Query10/Query10.WindowLogFiles/Window.Assign+Query10/Query10/Query10.GroupByKey2/Reify+Query10/Query10/Query10.GroupByKey2/Write
May 14, 2023 9:39:53 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:52.425Z: Finished operation
Query10/Query10/Query10.GroupByKey/Read+Query10/Query10/Query10.GroupByKey/GroupByWindow+Query10/Query10/Query10.CheckForLateEvents/ParMultiDo(Anonymous)+Query10/Query10/Query10.UploadEvents/ParMultiDo(Anonymous)+Query10/Query10/Query10.WindowLogFiles/Window.Assign+Query10/Query10/Query10.GroupByKey2/Reify+Query10/Query10/Query10.GroupByKey2/Write
May 14, 2023 9:39:53 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:52.484Z: Executing operation
Query10/Query10/Query10.GroupByKey2/Close
May 14, 2023 9:39:53 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:52.586Z: Finished operation
Query10/Query10/Query10.GroupByKey2/Close
May 14, 2023 9:39:53 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:52.655Z: Executing operation
Query10/Query10/Query10.GroupByKey2/Read+Query10/Query10/Query10.GroupByKey2/GroupByWindow+Query10/Query10/Query10.Index/ParMultiDo(Anonymous)+Query10/Query10.Debug/ParMultiDo(Monitor)+Query10/Query10.Stamp/ParMultiDo(Anonymous)+Query10.Format/ParMultiDo(Anonymous)+Query10.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:53 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:53.164Z: Finished operation
Query10/Query10/Query10.GroupByKey2/Read+Query10/Query10/Query10.GroupByKey2/GroupByWindow+Query10/Query10/Query10.Index/ParMultiDo(Anonymous)+Query10/Query10.Debug/ParMultiDo(Monitor)+Query10/Query10.Stamp/ParMultiDo(Anonymous)+Query10.Format/ParMultiDo(Anonymous)+Query10.DevNull/ParMultiDo(Anonymous)
May 14, 2023 9:39:54 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:53.306Z: Cleaning up.
May 14, 2023 9:39:54 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-05-14T09:39:53.382Z: Stopping **** pool...
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
May 14, 2023 9:40:55 AM org.apache.beam.runners.dataflow.DataflowPipelineJob
waitUntilFinish
WARNING: No terminal state was returned within allotted timeout. State value
RUNNING
> Task :runners:google-cloud-dataflow-java:cleanUpDockerJavaImages
WARNING: Successfully resolved tag to sha256, but it is recommended to use
sha256 directly.
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20230514092452]
- referencing digest:
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:0580e494e551db4fd2f27b56612f592eb88e42c7b54329738ac31d6aaee98e9b]
Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20230514092452]
(referencing
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:0580e494e551db4fd2f27b56612f592eb88e42c7b54329738ac31d6aaee98e9b])].
Digests:
-
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:0580e494e551db4fd2f27b56612f592eb88e42c7b54329738ac31d6aaee98e9b
Deleted
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:0580e494e551db4fd2f27b56612f592eb88e42c7b54329738ac31d6aaee98e9b].
Digests:
-
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:24a269fdb18efa5e1ee5ea83650be8b010f779376b18e8442a1c5c1eac68c38d
ERROR: (gcloud.container.images.delete) Not found: response:
{'docker-distribution-api-version': 'registry/2.0', 'content-type':
'application/json', 'content-encoding': 'gzip', 'date': 'Sun, 14 May 2023
09:42:19 GMT', 'server': 'Docker Registry', 'cache-control': 'private',
'x-xss-protection': '0', 'x-frame-options': 'SAMEORIGIN', 'transfer-encoding':
'chunked', 'status': 404}
Failed to compute blob liveness for manifest:
'sha256:24a269fdb18efa5e1ee5ea83650be8b010f779376b18e8442a1c5c1eac68c38d': None
> Task :runners:google-cloud-dataflow-java:cleanUpDockerJavaImages FAILED
FAILURE: Build failed with an exception.
* Where:
Build file
'<https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow_V2_Java17/ws/src/runners/google-cloud-dataflow-java/build.gradle'>
line: 305
* What went wrong:
Execution failed for task
':runners:google-cloud-dataflow-java:cleanUpDockerJavaImages'.
> Process 'command './scripts/cleanup_untagged_gcr_images.sh'' finished with
> non-zero exit value 1
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.5.1/userguide/command_line_interface.html#sec:command_line_warnings
Execution optimizations have been disabled for 1 invalid unit(s) of work during
this build to ensure correctness.
Please consult deprecation warnings for more details.
BUILD FAILED in 17m 53s
143 actionable tasks: 141 executed, 2 up-to-date
Publishing build scan...
https://ge.apache.org/s/7um7ujnh3jfyk
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
