See <https://ci-beam.apache.org/job/beam_PostCommit_Java_Nexmark_Dataflow/10713/display/redirect>
Changes: ------------------------------------------ [...truncated 1.49 MB...] Oct 05, 2023 2:21:45 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.179Z: Fusing consumer SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SideToRows/ParDo(Anonymous) into NexmarkUtils.GenerateSideInputData/MapElements/Map Oct 05, 2023 2:21:45 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.198Z: Fusing consumer SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/extractKeyrhs into SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SideToRows/ParDo(Anonymous) Oct 05, 2023 2:21:45 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.223Z: Fusing consumer SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/MakeUnionTable1 into SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/extractKeyrhs Oct 05, 2023 2:21:45 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.506Z: Executing operation SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Create Oct 05, 2023 2:21:45 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.583Z: Starting 4 ****s in us-central1-b... Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:44.960Z: Executing operation ZetaSqlQuery2.ReadBounded+ZetaSqlQuery2/ZetaSqlQuery2.Monitor+ZetaSqlQuery2/ZetaSqlQuery2.Snoop+ZetaSqlQuery2/ZetaSqlQuery2/Filter/ParDo(Anonymous)+ZetaSqlQuery2/ZetaSqlQuery2/ZetaSqlQuery2.SelectEvent/ParDo(Anonymous)+ZetaSqlQuery2/ZetaSqlQuery2/SqlTransform/BeamZetaSqlCalcRel_132/ParMultiDo(Calc)+ZetaSqlQuery2/ZetaSqlQuery2/Convert.ConvertTransform/ParDo(Anonymous)+ZetaSqlQuery2/ZetaSqlQuery2.Debug+ZetaSqlQuery2/ZetaSqlQuery2.Stamp+ZetaSqlQuery2.Format+ZetaSqlQuery2.DevNull Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.021Z: Starting 4 ****s in us-central1-b... Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.740Z: Expanding CoGroupByKey operations into optimizable parts. Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.774Z: Expanding GroupByKey operations into optimizable parts. Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.796Z: Lifting ValueCombiningMappingFns into MergeBucketsMappingFns Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.846Z: Fusing adjacent ParDo, Read, Write, and Flatten operations Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.865Z: Fusing consumer SqlQuery0/SqlQuery0.Monitor into SqlQuery0.ReadBounded Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.893Z: Fusing consumer SqlQuery0/SqlQuery0.Snoop into SqlQuery0/SqlQuery0.Monitor Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.920Z: Fusing consumer SqlQuery0/SqlQuery0/Filter/ParDo(Anonymous) into SqlQuery0/SqlQuery0.Snoop Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.945Z: Fusing consumer SqlQuery0/SqlQuery0/SqlQuery0.SelectEvent/ParDo(Anonymous) into SqlQuery0/SqlQuery0/Filter/ParDo(Anonymous) Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.967Z: Fusing consumer SqlQuery0/SqlQuery0/SqlQuery0.Serialize into SqlQuery0/SqlQuery0/SqlQuery0.SelectEvent/ParDo(Anonymous) Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.989Z: Fusing consumer SqlQuery0/SqlQuery0/SqlTransform/BeamZetaSqlCalcRel_120/ParMultiDo(Calc) into SqlQuery0/SqlQuery0/SqlQuery0.Serialize Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:46.014Z: Fusing consumer SqlQuery0/SqlQuery0/Convert.ConvertTransform/ParDo(Anonymous) into SqlQuery0/SqlQuery0/SqlTransform/BeamZetaSqlCalcRel_120/ParMultiDo(Calc) Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:46.035Z: Fusing consumer SqlQuery0/SqlQuery0.Debug into SqlQuery0/SqlQuery0/Convert.ConvertTransform/ParDo(Anonymous) Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:46.056Z: Fusing consumer SqlQuery0/SqlQuery0.Stamp into SqlQuery0/SqlQuery0.Debug Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:46.081Z: Fusing consumer SqlQuery0.Format into SqlQuery0/SqlQuery0.Stamp Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:46.106Z: Fusing consumer SqlQuery0.DevNull into SqlQuery0.Format Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:46.388Z: Executing operation SqlQuery0.ReadBounded+SqlQuery0/SqlQuery0.Monitor+SqlQuery0/SqlQuery0.Snoop+SqlQuery0/SqlQuery0/Filter/ParDo(Anonymous)+SqlQuery0/SqlQuery0/SqlQuery0.SelectEvent/ParDo(Anonymous)+SqlQuery0/SqlQuery0/SqlQuery0.Serialize+SqlQuery0/SqlQuery0/SqlTransform/BeamZetaSqlCalcRel_120/ParMultiDo(Calc)+SqlQuery0/SqlQuery0/Convert.ConvertTransform/ParDo(Anonymous)+SqlQuery0/SqlQuery0.Debug+SqlQuery0/SqlQuery0.Stamp+SqlQuery0.Format+SqlQuery0.DevNull Oct 05, 2023 2:21:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:46.449Z: Starting 4 ****s in us-central1-b... Oct 05, 2023 2:21:47 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:44.901Z: Executing operation ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Create Oct 05, 2023 2:21:47 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:44.964Z: Starting 4 ****s in us-central1-b... Oct 05, 2023 2:21:47 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:45.209Z: Finished operation ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Create Oct 05, 2023 2:21:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:46.061Z: Finished operation SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Create Oct 05, 2023 2:21:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:54.125Z: Executing operation ZetaSqlQuery3.ReadBounded+ZetaSqlQuery3/ZetaSqlQuery3.Monitor+ZetaSqlQuery3/ZetaSqlQuery3.Snoop+ZetaSqlQuery3/ZetaSqlQuery3/Window.Into()/Window.Assign+ZetaSqlQuery3/ZetaSqlQuery3/ZetaSqlQuery3.Filter.Auction/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3/ZetaSqlQuery3.Filter.Person/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3/ZetaSqlQuery3.ToRecords.Person/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamZetaSqlCalcRel_305/ParMultiDo(Calc)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/extractKeyrhs+ZetaSqlQuery3/ZetaSqlQuery3/ZetaSqlQuery3.ToRecords.Auction/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamZetaSqlCalcRel_304/ParMultiDo(Calc)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/extractKeylhs+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/MakeUnionTable0+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Reify+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/MakeUnionTable1+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Reify+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Session/Flatten+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Write Oct 05, 2023 2:21:56 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:54.753Z: Executing operation NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)+NexmarkUtils.GenerateSideInputData/MapElements/Map+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SideToRows/ParDo(Anonymous)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/extractKeyrhs+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/MakeUnionTable1+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Reify+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Write Oct 05, 2023 2:21:56 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:54.778Z: Executing operation SqlBoundedSideInputJoin.ReadBounded+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin.Monitor+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin.Snoop+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/Filter/ParDo(Anonymous)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlBoundedSideInputJoin.SelectEvent/ParDo(Anonymous)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamZetaSqlCalcRel_290/ParMultiDo(Calc)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/extractKeylhs+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/MakeUnionTable0+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Reify+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Write Oct 05, 2023 2:21:57 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:21:56.197Z: 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 Oct 05, 2023 2:22:02 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:00.229Z: 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 Oct 05, 2023 2:22:05 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:04.896Z: 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 Oct 05, 2023 2:22:12 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:12.358Z: 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 Oct 05, 2023 2:22:36 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:36.179Z: Autoscaling: Raised the number of ****s to 4 based on the rate of progress in the currently running stage(s). Oct 05, 2023 2:22:37 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:35.212Z: Autoscaling: Raised the number of ****s to 3 based on the rate of progress in the currently running stage(s). Oct 05, 2023 2:22:37 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:35.230Z: Autoscaling: Resized **** pool to 3, though goal was 4. This could be a quota issue. Oct 05, 2023 2:22:37 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:36.390Z: Autoscaling: Raised the number of ****s to 2 based on the rate of progress in the currently running stage(s). Oct 05, 2023 2:22:37 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:36.411Z: Autoscaling: Resized **** pool to 2, though goal was 4. This could be a quota issue. Oct 05, 2023 2:22:38 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:37.388Z: Autoscaling: Raised the number of ****s to 4 based on the rate of progress in the currently running stage(s). Oct 05, 2023 2:22:46 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:45.039Z: Autoscaling: Raised the number of ****s to 4 based on the rate of progress in the currently running stage(s). Oct 05, 2023 2:22:47 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:22:46.206Z: Autoscaling: Raised the number of ****s to 4 based on the rate of progress in the currently running stage(s). Oct 05, 2023 2:23:11 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:23:09.831Z: Workers have started successfully. Oct 05, 2023 2:23:12 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:23:11.606Z: Workers have started successfully. Oct 05, 2023 2:23:13 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:23:13.767Z: Workers have started successfully. Oct 05, 2023 2:23:15 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:23:13.699Z: Workers have started successfully. Oct 05, 2023 2:23:32 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:23:32.246Z: All ****s have finished the startup processes and began to receive work requests. Oct 05, 2023 2:23:36 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:23:35.764Z: All ****s have finished the startup processes and began to receive work requests. Oct 05, 2023 2:23:41 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:23:40.520Z: All ****s have finished the startup processes and began to receive work requests. Oct 05, 2023 2:23:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:23:47.545Z: All ****s have finished the startup processes and began to receive work requests. Oct 05, 2023 2:23:50 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:23:49.471Z: Finished operation NexmarkUtils.GenerateSideInputData/GenerateSequence/Read(BoundedCountingSource)+NexmarkUtils.GenerateSideInputData/MapElements/Map+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SideToRows/ParDo(Anonymous)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/extractKeyrhs+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/MakeUnionTable1+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Reify+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Write Oct 05, 2023 2:24:37 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:34.893Z: Finished operation ZetaSqlQuery3.ReadBounded+ZetaSqlQuery3/ZetaSqlQuery3.Monitor+ZetaSqlQuery3/ZetaSqlQuery3.Snoop+ZetaSqlQuery3/ZetaSqlQuery3/Window.Into()/Window.Assign+ZetaSqlQuery3/ZetaSqlQuery3/ZetaSqlQuery3.Filter.Auction/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3/ZetaSqlQuery3.Filter.Person/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3/ZetaSqlQuery3.ToRecords.Person/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamZetaSqlCalcRel_305/ParMultiDo(Calc)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/extractKeyrhs+ZetaSqlQuery3/ZetaSqlQuery3/ZetaSqlQuery3.ToRecords.Auction/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamZetaSqlCalcRel_304/ParMultiDo(Calc)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/extractKeylhs+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/MakeUnionTable0+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Reify+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/MakeUnionTable1+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Reify+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Session/Flatten+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Write Oct 05, 2023 2:24:37 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:34.948Z: Executing operation ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Close Oct 05, 2023 2:24:37 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:34.999Z: Finished operation ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Close Oct 05, 2023 2:24:37 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:35.054Z: Executing operation ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Read+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/GroupByWindow+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/ConstructCoGbkResultFn+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/ParDo(ConvertCoGbkResult)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Select.Fields/ParDo(Select)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamZetaSqlCalcRel_307/ParMultiDo(Calc)+ZetaSqlQuery3/ZetaSqlQuery3/Convert.ConvertTransform/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3.Debug+ZetaSqlQuery3/ZetaSqlQuery3.Stamp+ZetaSqlQuery3.Format+ZetaSqlQuery3.DevNull Oct 05, 2023 2:24:42 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:41.318Z: Finished operation ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Read+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/GroupByWindow+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/ConstructCoGbkResultFn+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Join.Impl/CoGroup.ExpandCrossProduct/ParDo(ConvertCoGbkResult)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamCoGBKJoinRel_306/Select.Fields/ParDo(Select)+ZetaSqlQuery3/ZetaSqlQuery3/SqlTransform/BeamZetaSqlCalcRel_307/ParMultiDo(Calc)+ZetaSqlQuery3/ZetaSqlQuery3/Convert.ConvertTransform/ParDo(Anonymous)+ZetaSqlQuery3/ZetaSqlQuery3.Debug+ZetaSqlQuery3/ZetaSqlQuery3.Stamp+ZetaSqlQuery3.Format+ZetaSqlQuery3.DevNull Oct 05, 2023 2:24:42 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:41.420Z: Cleaning up. Oct 05, 2023 2:24:42 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:41.482Z: Stopping **** pool... Oct 05, 2023 2:24:53 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:52.942Z: Finished operation ZetaSqlQuery2.ReadBounded+ZetaSqlQuery2/ZetaSqlQuery2.Monitor+ZetaSqlQuery2/ZetaSqlQuery2.Snoop+ZetaSqlQuery2/ZetaSqlQuery2/Filter/ParDo(Anonymous)+ZetaSqlQuery2/ZetaSqlQuery2/ZetaSqlQuery2.SelectEvent/ParDo(Anonymous)+ZetaSqlQuery2/ZetaSqlQuery2/SqlTransform/BeamZetaSqlCalcRel_132/ParMultiDo(Calc)+ZetaSqlQuery2/ZetaSqlQuery2/Convert.ConvertTransform/ParDo(Anonymous)+ZetaSqlQuery2/ZetaSqlQuery2.Debug+ZetaSqlQuery2/ZetaSqlQuery2.Stamp+ZetaSqlQuery2.Format+ZetaSqlQuery2.DevNull Oct 05, 2023 2:24:53 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:53.057Z: Cleaning up. Oct 05, 2023 2:24:53 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:24:53.128Z: Stopping **** pool... Oct 05, 2023 2:25:05 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:25:04.787Z: Finished operation SqlQuery0.ReadBounded+SqlQuery0/SqlQuery0.Monitor+SqlQuery0/SqlQuery0.Snoop+SqlQuery0/SqlQuery0/Filter/ParDo(Anonymous)+SqlQuery0/SqlQuery0/SqlQuery0.SelectEvent/ParDo(Anonymous)+SqlQuery0/SqlQuery0/SqlQuery0.Serialize+SqlQuery0/SqlQuery0/SqlTransform/BeamZetaSqlCalcRel_120/ParMultiDo(Calc)+SqlQuery0/SqlQuery0/Convert.ConvertTransform/ParDo(Anonymous)+SqlQuery0/SqlQuery0.Debug+SqlQuery0/SqlQuery0.Stamp+SqlQuery0.Format+SqlQuery0.DevNull Oct 05, 2023 2:25:05 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:25:04.955Z: Cleaning up. Oct 05, 2023 2:25:05 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:25:05.041Z: Stopping **** pool... Oct 05, 2023 2:25:12 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:25:12.346Z: Finished operation SqlBoundedSideInputJoin.ReadBounded+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin.Monitor+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin.Snoop+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/Filter/ParDo(Anonymous)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlBoundedSideInputJoin.SelectEvent/ParDo(Anonymous)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamZetaSqlCalcRel_290/ParMultiDo(Calc)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/extractKeylhs+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/MakeUnionTable0+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Reify+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Write Oct 05, 2023 2:25:12 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:25:12.400Z: Executing operation SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Close Oct 05, 2023 2:25:12 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:25:12.467Z: Finished operation SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Close Oct 05, 2023 2:25:12 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO: 2023-10-05T14:25:12.514Z: Executing operation SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/Read+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/GBK/GroupByWindow+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/CoGroupByKey/ConstructCoGbkResultFn+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Join.Impl/CoGroup.ExpandCrossProduct/ParDo(ConvertCoGbkResult)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamCoGBKJoinRel_291/Select.Fields/ParDo(Select)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/SqlTransform/BeamZetaSqlCalcRel_292/ParMultiDo(Calc)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin/ResultToBid/ParDo(Anonymous)+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin.Debug+SqlBoundedSideInputJoin/SqlBoundedSideInputJoin.Stamp+SqlBoundedSideInputJoin.Format+SqlBoundedSideInputJoin.DevNull Oct 05, 2023 2:25:31 PM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING 2023-10-05T14:25:31.684Z Waiting for main pipeline to 'finish' Oct 05, 2023 2:25:31 PM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING 2023-10-05T14:25:31.700Z Waiting for main pipeline to 'finish' Oct 05, 2023 2:25:31 PM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish 2023-10-05T14:25:31.709Z Waiting for main pipeline to 'finish' WARNING: No terminal state was returned within allotted timeout. State value RUNNING 2023-10-05T14:25:31.727Z RUNNING ZetaSqlQuery3 2023-10-05T14:25:31.730Z RUNNING SqlQuery0 2023-10-05T14:25:31.734Z RUNNING SqlBoundedSideInputJoin Oct 05, 2023 2:25:31 PM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish WARNING: No terminal state was returned within allotted timeout. State value RUNNING 2023-10-05T14:25:31.763Z Waiting for main pipeline to 'finish' 2023-10-05T14:25:31.784Z RUNNING ZetaSqlQuery2 2023-10-05T14:25:32.709Z new perf {"snapshots":null,"runtimeSec":86.879,"numEvents":10000000,"eventsPerSec":115102.61398036349,"eventBytesPerSec":1.4774167485813603E7,"numResults":9200000,"resultsPerSec":105894.40486193441,"resultBytesPerSec":1.0642324911658743E7,"startupDelaySec":-113.841,"processingDelaySec":0.635,"shutdownDelaySec":26.962,"timeDilation":11.509685884966448,"errors":null,"jobId":null} 2023-10-05T14:25:32.719Z new perf {"snapshots":null,"runtimeSec":59.486,"numEvents":10000000,"eventsPerSec":168106.7814275628,"eventBytesPerSec":2.1577596358807117E7,"numResults":9054,"resultsPerSec":152.20387990451536,"resultBytesPerSec":4861.05974515012,"startupDelaySec":-109.903,"processingDelaySec":53.786,"shutdownDelaySec":50.417,"timeDilation":16.68459805668561,"errors":null,"jobId":null} 2023-10-05T14:25:32.697Z new perf {"snapshots":null,"runtimeSec":61.573,"numEvents":10000000,"eventsPerSec":162408.8480340409,"eventBytesPerSec":2.0846229629870236E7,"numResults":83527,"resultsPerSec":1356.5523849739334,"resultBytesPerSec":21704.838159582934,"startupDelaySec":-100.468,"processingDelaySec":0.594,"shutdownDelaySec":38.913,"timeDilation":16.239910350315885,"errors":null,"jobId":null} 2023-10-05T14:25:32.786Z new perf {"snapshots":null,"runtimeSec":90.792,"numEvents":10000000,"eventsPerSec":110141.8627191823,"eventBytesPerSec":1.4137422867653538E7,"numResults":241406,"resultsPerSec":2658.8906511586924,"resultBytesPerSec":95264.825094722,"startupDelaySec":-104.558,"processingDelaySec":86.036,"shutdownDelaySec":13.766,"timeDilation":-1.0,"errors":null,"jobId":null} 2023-10-05T14:25:47.776Z RUNNING SqlQuery0 2023-10-05T14:25:47.784Z RUNNING ZetaSqlQuery2 2023-10-05T14:25:47.786Z RUNNING ZetaSqlQuery3 2023-10-05T14:25:47.854Z RUNNING SqlBoundedSideInputJoin 2023-10-05T14:25:48.346Z no activity 2023-10-05T14:25:48.377Z no activity 2023-10-05T14:25:48.443Z no activity 2023-10-05T14:25:48.551Z new perf {"snapshots":null,"runtimeSec":105.919,"numEvents":10000000,"eventsPerSec":94411.76748269904,"eventBytesPerSec":1.2118363060451856E7,"numResults":1118640,"resultsPerSec":10561.277957684646,"resultBytesPerSec":378372.9925697939,"startupDelaySec":-104.558,"processingDelaySec":86.084,"shutdownDelaySec":14.716,"timeDilation":-1.0,"errors":null,"jobId":null} 2023-10-05T14:26:03.391Z RUNNING ZetaSqlQuery2 2023-10-05T14:26:03.422Z RUNNING SqlQuery0 2023-10-05T14:26:03.497Z RUNNING ZetaSqlQuery3 2023-10-05T14:26:03.605Z RUNNING SqlBoundedSideInputJoin 2023-10-05T14:26:04.012Z no activity 2023-10-05T14:26:04.094Z no activity 2023-10-05T14:26:04.210Z no activity 2023-10-05T14:26:04.267Z new perf {"snapshots":null,"runtimeSec":131.844,"numEvents":10000000,"eventsPerSec":75847.21337338067,"eventBytesPerSec":9735482.062134037,"numResults":1904663,"resultsPerSec":14446.338096538333,"resultBytesPerSec":516912.30545189773,"startupDelaySec":-104.558,"processingDelaySec":86.084,"shutdownDelaySec":4.556,"timeDilation":-1.0,"errors":null,"jobId":null} 2023-10-05T14:26:19.191Z RUNNING ZetaSqlQuery2 2023-10-05T14:26:19.197Z RUNNING SqlQuery0 2023-10-05T14:26:19.282Z RUNNING ZetaSqlQuery3 2023-10-05T14:26:19.328Z RUNNING SqlBoundedSideInputJoin 2023-10-05T14:26:19.736Z no activity 2023-10-05T14:26:19.756Z no activity 2023-10-05T14:26:19.900Z no activity 2023-10-05T14:26:20.026Z no activity Oct 05, 2023 2:30:40 PM org.apache.beam.sdk.metrics.MetricsEnvironment getCurrentContainer WARNING: Reporting metrics are not supported in the current execution environment. Oct 05, 2023 2:45:55 PM org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer$LoggingHttpBackOffHandler handleIOException WARNING: Request failed with IOException, performed 4 retries due to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2023-10-05_07_21_30-12823991383227883969 Oct 05, 2023 2:45:55 PM org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer$LoggingHttpBackOffHandler handleIOException WARNING: Request failed with IOException, performed 4 retries due to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2023-10-05_07_21_30-15451378091083783969 Oct 05, 2023 2:45:51 PM org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer$LoggingHttpBackOffHandler handleIOException WARNING: Request failed with IOException, performed 4 retries due to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2023-10-05_07_21_30-6386387710547691900 Oct 05, 2023 2:47:29 PM org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer$LoggingHttpBackOffHandler handleIOException WARNING: Request failed with IOException, performed 2 retries due to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2023-10-05_07_21_30-17060748116975647599 Oct 05, 2023 2:48:49 PM org.apache.beam.runners.dataflow.DataflowPipelineJob getJobWithRetries WARNING: There were problems getting current job status: dataflow.googleapis.com. Oct 05, 2023 2:48:53 PM org.apache.beam.runners.dataflow.DataflowPipelineJob getJobWithRetries WARNING: There were problems getting current job status: dataflow.googleapis.com. Oct 05, 2023 2:48:56 PM org.apache.beam.runners.dataflow.DataflowPipelineJob getJobWithRetries WARNING: There were problems getting current job status: dataflow.googleapis.com. Oct 05, 2023 2:48:49 PM org.apache.beam.runners.dataflow.DataflowPipelineJob getJobWithRetries WARNING: There were problems getting current job status: dataflow.googleapis.com. Oct 05, 2023 3:12:11 PM org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer$LoggingHttpBackOffHandler handleIOException WARNING: Request failed with IOException, performed 2 retries due to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2023-10-05_07_21_30-17060748116975647599 Oct 05, 2023 3:12:11 PM org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer$LoggingHttpBackOffHandler handleIOException WARNING: Request failed with IOException, performed 2 retries due to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2023-10-05_07_21_30-12823991383227883969 Oct 05, 2023 3:12:11 PM org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer$LoggingHttpBackOffHandler handleIOException WARNING: Request failed with IOException, performed 2 retries due to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2023-10-05_07_21_30-6386387710547691900 Oct 05, 2023 3:12:11 PM org.apache.beam.sdk.extensions.gcp.util.RetryHttpRequestInitializer$LoggingHttpBackOffHandler handleIOException WARNING: Request failed with IOException, performed 2 retries due to IOExceptions, performed 0 retries due to unsuccessful status codes, HTTP framework says request can be retried, (caller responsible for retrying): https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/locations/us-central1/jobs/2023-10-05_07_21_30-15451378091083783969 Oct 05, 2023 3:12:11 PM org.apache.beam.runners.dataflow.DataflowPipelineJob getJobWithRetries WARNING: There were problems getting current job status: dataflow.googleapis.com. Oct 05, 2023 3:12:11 PM org.apache.beam.runners.dataflow.DataflowPipelineJob getJobWithRetries WARNING: There were problems getting current job status: dataflow.googleapis.com. Oct 05, 2023 3:12:11 PM org.apache.beam.runners.dataflow.DataflowPipelineJob getJobWithRetries WARNING: There were problems getting current job status: dataflow.googleapis.com. Oct 05, 2023 3:12:11 PM org.apache.beam.runners.dataflow.DataflowPipelineJob getJobWithRetries WARNING: There were problems getting current job status: null. FATAL: command execution failed hudson.remoting.ChannelClosedException: Channel "hudson.remoting.Channel@6c1c0a01:apache-beam-jenkins-1": Remote call on apache-beam-jenkins-1 failed. The channel is closing down or has closed down at hudson.remoting.Channel.call(Channel.java:993) at hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285) at com.sun.proxy.$Proxy141.isAlive(Unknown Source) at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1215) at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1207) at hudson.Launcher$ProcStarter.join(Launcher.java:524) at hudson.plugins.gradle.Gradle.perform(Gradle.java:321) at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20) at hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:814) at hudson.model.Build$BuildExecution.build(Build.java:199) at hudson.model.Build$BuildExecution.doRun(Build.java:164) at hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:522) at hudson.model.Run.execute(Run.java:1896) at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44) at hudson.model.ResourceController.execute(ResourceController.java:101) at hudson.model.Executor.run(Executor.java:442) 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.base/java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2911) at java.base/java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:3406) at java.base/java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:932) at java.base/java.io.ObjectInputStream.<init>(ObjectInputStream.java:375) 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-1 is offline; cannot locate jdk_1.8_latest --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
