See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow_V2/302/display/redirect>
Changes: ------------------------------------------ [...truncated 195.53 KB...] INFO: 2021-08-08T00:13:20.012Z: Workers have started successfully. Aug 08, 2021 12:13:20 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:20.046Z: Workers have started successfully. Aug 08, 2021 12:13:28 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:27.403Z: Finished operation Query1.ReadBounded/Impulse+Query1.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query1-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query1-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing Aug 08, 2021 12:13:28 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:27.530Z: Executing 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) Aug 08, 2021 12:13:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:30.091Z: Finished operation Query0.ReadBounded/Impulse+Query0.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query0-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query0-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing Aug 08, 2021 12:13:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:30.252Z: Executing 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) Aug 08, 2021 12:13:32 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:30.893Z: 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 Aug 08, 2021 12:13:32 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:31.002Z: Executing operation Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create Aug 08, 2021 12:13:32 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:31.911Z: Finished operation Query2.ReadBounded/Impulse+Query2.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query2-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query2-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing Aug 08, 2021 12:13:32 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:32.032Z: Executing 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) Aug 08, 2021 12:13:33 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:32.474Z: Finished operation Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create Aug 08, 2021 12:13:33 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:32.602Z: 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 Aug 08, 2021 12:13:35 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:35.331Z: Finished operation Query11.ReadBounded/Impulse+Query11.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query11-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query11-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing Aug 08, 2021 12:13:35 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:35.551Z: Executing operation Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create Aug 08, 2021 12:13:37 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:35.762Z: Finished operation Query8.ReadBounded/Impulse+Query8.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query8-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query8-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing Aug 08, 2021 12:13:37 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:35.920Z: Executing operation Query8/Query8/CoGroupByKey/GBK/Create Aug 08, 2021 12:13:38 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:37.229Z: Finished operation Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create Aug 08, 2021 12:13:38 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:37.437Z: Executing 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 Aug 08, 2021 12:13:38 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:36.743Z: 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 Aug 08, 2021 12:13:38 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:36.913Z: Executing operation Query10/Query10/Query10.GroupByKey/Create Aug 08, 2021 12:13:39 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:38.488Z: Finished operation Query10/Query10/Query10.GroupByKey/Create Aug 08, 2021 12:13:39 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:38.643Z: 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 Aug 08, 2021 12:13:39 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:38.137Z: Finished operation Query13.ReadBounded/Impulse+Query13.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query13-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query13-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing Aug 08, 2021 12:13:39 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:38.293Z: Executing operation Query13/Query13/GroupByKey/Create Aug 08, 2021 12:13:40 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:37.385Z: Finished operation Query8/Query8/CoGroupByKey/GBK/Create Aug 08, 2021 12:13:40 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:37.546Z: Executing 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 Aug 08, 2021 12:13:41 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:40.492Z: Finished operation Query13/Query13/GroupByKey/Create Aug 08, 2021 12:13:41 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:40.632Z: Executing 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 Aug 08, 2021 12:13:41 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:39.336Z: Finished operation Query12.ReadBounded/Impulse+Query12.ReadBounded/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+Query12-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/PairWithRestriction+Query12-ReadBounded-ParDo-BoundedSourceAsSDFWrapper--ParMultiDo-BoundedSourceAsSDFWrapper-/SplitWithSizing Aug 08, 2021 12:13:41 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:39.465Z: Executing operation Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create Aug 08, 2021 12:13:41 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:41.019Z: Finished operation Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create Aug 08, 2021 12:13:41 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:41.145Z: 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 Aug 08, 2021 12:13:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:53.385Z: 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) Aug 08, 2021 12:13:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:53.523Z: Cleaning up. Aug 08, 2021 12:13:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:53.609Z: Stopping **** pool... Aug 08, 2021 12:13:57 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:56.574Z: 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) Aug 08, 2021 12:13:57 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:56.743Z: Cleaning up. Aug 08, 2021 12:13:57 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:56.839Z: Stopping **** pool... Aug 08, 2021 12:14:00 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:59.046Z: 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 Aug 08, 2021 12:14:00 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:59.089Z: Executing operation Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close Aug 08, 2021 12:14:00 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:59.138Z: Finished operation Query5/Query5/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close Aug 08, 2021 12:14:00 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:59.204Z: Executing operation Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Create Aug 08, 2021 12:14:00 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:59.363Z: Finished operation Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Create Aug 08, 2021 12:14:00 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:59.489Z: Executing operation Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Create Aug 08, 2021 12:14:00 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:59.633Z: Finished operation Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Create Aug 08, 2021 12:14:00 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:13:59.733Z: 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 Aug 08, 2021 12:14:01 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:00.979Z: 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 Aug 08, 2021 12:14:01 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:01.054Z: Executing operation Query8/Query8/CoGroupByKey/GBK/Close Aug 08, 2021 12:14:03 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:01.111Z: Finished operation Query8/Query8/CoGroupByKey/GBK/Close Aug 08, 2021 12:14:03 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:01.173Z: 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) Aug 08, 2021 12:14:06 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:04.369Z: 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 Aug 08, 2021 12:14:06 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:04.454Z: Executing operation Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close Aug 08, 2021 12:14:06 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:04.501Z: Finished operation Query12/Query12/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close Aug 08, 2021 12:14:06 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:04.564Z: 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) Aug 08, 2021 12:14:07 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:07.071Z: 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) Aug 08, 2021 12:14:07 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:07.415Z: Cleaning up. Aug 08, 2021 12:14:07 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:07.551Z: Stopping **** pool... Aug 08, 2021 12:14:08 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:07.828Z: 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) Aug 08, 2021 12:14:08 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:07.999Z: Cleaning up. Aug 08, 2021 12:14:08 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:08.082Z: Stopping **** pool... Aug 08, 2021 12:14:08 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:07.941Z: 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 Aug 08, 2021 12:14:08 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:07.997Z: Executing operation Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Close Aug 08, 2021 12:14:08 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:08.047Z: Finished operation Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PreCombineHot/GroupByKey/Close Aug 08, 2021 12:14:08 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:08.108Z: 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 Aug 08, 2021 12:14:12 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:10.878Z: 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 Aug 08, 2021 12:14:12 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:10.942Z: Executing operation Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Close Aug 08, 2021 12:14:12 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:11.002Z: Finished operation Query5/Query5/Combine.globally(Top)/Combine.perKeyWithFanout(Top)/PostCombine/GroupByKey/Close Aug 08, 2021 12:14:12 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:11.051Z: 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) Aug 08, 2021 12:14:12 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:11.742Z: 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) Aug 08, 2021 12:14:12 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:11.863Z: Cleaning up. Aug 08, 2021 12:14:12 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:11.937Z: Stopping **** pool... Aug 08, 2021 12:14:13 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:12.830Z: 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) Aug 08, 2021 12:14:13 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:12.988Z: Cleaning up. Aug 08, 2021 12:14:13 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:13.058Z: Stopping **** pool... Aug 08, 2021 12:14:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:13.859Z: 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 Aug 08, 2021 12:14:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:13.932Z: Executing operation Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close Aug 08, 2021 12:14:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:13.998Z: Finished operation Query11/Query11/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close Aug 08, 2021 12:14:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:14.082Z: 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) Aug 08, 2021 12:14:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:14.418Z: 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 Aug 08, 2021 12:14:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:14.496Z: Executing operation Query13/Query13/GroupByKey/Close Aug 08, 2021 12:14:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:14.571Z: Finished operation Query13/Query13/GroupByKey/Close Aug 08, 2021 12:14:17 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:14.655Z: 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) Aug 08, 2021 12:14:18 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:16.231Z: 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 Aug 08, 2021 12:14:18 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:16.292Z: Executing operation Query10/Query10/Query10.GroupByKey/Close Aug 08, 2021 12:14:18 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:16.347Z: Finished operation Query10/Query10/Query10.GroupByKey/Close Aug 08, 2021 12:14:18 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:16.419Z: Executing operation Query10/Query10/Query10.GroupByKey2/Create Aug 08, 2021 12:14:18 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:16.571Z: Finished operation Query10/Query10/Query10.GroupByKey2/Create Aug 08, 2021 12:14:18 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:16.709Z: 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 Aug 08, 2021 12:14:26 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:26.349Z: 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) Aug 08, 2021 12:14:26 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:26.507Z: Cleaning up. Aug 08, 2021 12:14:28 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:26.601Z: Stopping **** pool... Aug 08, 2021 12:14:40 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:39.455Z: 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 Aug 08, 2021 12:14:40 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:39.529Z: Executing operation Query10/Query10/Query10.GroupByKey2/Close Aug 08, 2021 12:14:40 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:39.585Z: Finished operation Query10/Query10/Query10.GroupByKey2/Close Aug 08, 2021 12:14:40 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:39.667Z: 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) Aug 08, 2021 12:14:44 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:43.957Z: 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) Aug 08, 2021 12:14:47 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:47.005Z: Cleaning up. Aug 08, 2021 12:14:47 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:47.068Z: Stopping **** pool... Aug 08, 2021 12:14:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:49.581Z: 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) Aug 08, 2021 12:14:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:49.749Z: Cleaning up. Aug 08, 2021 12:14:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2021-08-08T00:14:49.832Z: Stopping **** pool... Aug 08, 2021 12:15:33 AM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING Aug 08, 2021 12:15:33 AM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING Aug 08, 2021 12:15:34 AM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING Aug 08, 2021 12:15:34 AM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING Aug 08, 2021 12:15:34 AM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING Aug 08, 2021 12:15:34 AM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING Aug 08, 2021 12:15:34 AM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING Aug 08, 2021 12:15:34 AM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING Aug 08, 2021 12:15:34 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:cleanUpDockerImages FAILED ERROR: (gcloud.container.images.untag) Image could not be found: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20210808000110] FAILURE: Build failed with an exception. * Where: Build file '<https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow_V2/ws/src/runners/google-cloud-dataflow-java/build.gradle'> line: 279 * What went wrong: Execution failed for task ':runners:google-cloud-dataflow-java:cleanUpDockerImages'. > Process 'command 'gcloud'' 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. 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 7.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/6.8.3/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 17m 27s 134 actionable tasks: 95 executed, 37 from cache, 2 up-to-date Publishing build scan... https://gradle.com/s/opuw4bvm3mzkq 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]
