See
<https://ci-beam.apache.org/job/beam_PerformanceTests_BiqQueryIO_Batch_Java_Avro/465/display/redirect>
Changes:
------------------------------------------
[...truncated 418.39 KB...]
INFO: 2023-02-21T16:30:14.869Z: Finished operation Write to
BQ/BatchLoads/JobIdCreationRoot_TEMP_TABLE_LOAD/Read(CreateSource)+Write to
BQ/BatchLoads/CreateJobId_TEMP_TABLE_LOAD+Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:14.940Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.110Z: Finished operation Write to
BQ/BatchLoads/JobIdCreationRoot_COPY/Read(CreateSource)+Write to
BQ/BatchLoads/CreateJobId_COPY+Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.184Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.256Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.256Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.301Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.341Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.374Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.409Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.481Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.498Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.505Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.583Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.593Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.661Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.728Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.747Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.779Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:17 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:15.899Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:19 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:18.461Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:19 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:18.524Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:19 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:18.577Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:19 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:18.662Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:19 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.315Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.398Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.460Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.535Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.717Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.811Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.857Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.884Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.926Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.973Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:19.987Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:20.060Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:21.335Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:21.473Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:21.521Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_TEMP_TABLE_LOAD/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.152Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.164Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.275Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.318Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.351Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.423Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_LOAD/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.429Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_COPY/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.467Z: Executing operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.604Z: Executing operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.605Z: Finished operation Write to
BQ/BatchLoads/JobIdSideInput_SCHEMA_UPDATE/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.755Z: Finished operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
Feb 21, 2023 4:30:24 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:22.882Z: Executing operation Write to
BQ/BatchLoads/Create dummy value/Read(CreateSource)+Write to
BQ/BatchLoads/GetTempFilePrefix+Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:24.405Z: Finished operation Write to
BQ/BatchLoads/Create dummy value/Read(CreateSource)+Write to
BQ/BatchLoads/GetTempFilePrefix+Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:24.497Z: Executing operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:24.586Z: Finished operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:24.682Z: Executing operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:24.834Z: Finished operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:25.040Z: Executing operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:26.256Z: Finished operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:26.331Z: Executing operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:26.390Z: Finished operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Feb 21, 2023 4:30:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:26.464Z: Executing operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:28.732Z: Finished operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+Write
to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Feb 21, 2023 4:30:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:28.866Z: Executing operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:28.927Z: Finished operation Write to
BQ/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/CreateDataflowView
Feb 21, 2023 4:30:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:29.070Z: Executing operation Write to
BQ/BatchLoads/GroupByDestination/Create
Feb 21, 2023 4:30:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:29.206Z: Finished operation Write to
BQ/BatchLoads/GroupByDestination/Create
Feb 21, 2023 4:30:30 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:30:29.332Z: Executing operation Read from source+Gather
time+Map records+Write to BQ/PrepareWrite/ParDo(Anonymous)+Write to
BQ/BatchLoads/rewindowIntoGlobal/Window.Assign+Write to
BQ/BatchLoads/WriteBundlesToFiles+Write to
BQ/BatchLoads/ReifyResults/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+Write
to BQ/BatchLoads/GroupByDestination/Reify+Write to
BQ/BatchLoads/GroupByDestination/Write
Feb 21, 2023 4:31:03 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:02.575Z: Finished operation Read from source+Gather
time+Map records+Write to BQ/PrepareWrite/ParDo(Anonymous)+Write to
BQ/BatchLoads/rewindowIntoGlobal/Window.Assign+Write to
BQ/BatchLoads/WriteBundlesToFiles+Write to
BQ/BatchLoads/ReifyResults/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+Write
to BQ/BatchLoads/GroupByDestination/Reify+Write to
BQ/BatchLoads/GroupByDestination/Write
Feb 21, 2023 4:31:03 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:02.674Z: Executing operation Write to
BQ/BatchLoads/GroupByDestination/Close
Feb 21, 2023 4:31:03 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:02.727Z: Finished operation Write to
BQ/BatchLoads/GroupByDestination/Close
Feb 21, 2023 4:31:03 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:02.782Z: Executing operation Write to
BQ/BatchLoads/GroupByDestination/Read+Write to
BQ/BatchLoads/GroupByDestination/GroupByWindow+Write to
BQ/BatchLoads/StripShardId/Map+Write to BQ/BatchLoads/WriteGroupedRecords+Write
to BQ/BatchLoads/ReifyResults/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
Feb 21, 2023 4:31:04 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:03.914Z: Finished operation Write to
BQ/BatchLoads/GroupByDestination/Read+Write to
BQ/BatchLoads/GroupByDestination/GroupByWindow+Write to
BQ/BatchLoads/StripShardId/Map+Write to BQ/BatchLoads/WriteGroupedRecords+Write
to BQ/BatchLoads/ReifyResults/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
Feb 21, 2023 4:31:04 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:04.094Z: Executing operation Write to
BQ/BatchLoads/FlattenFiles/Unzipped-1
Feb 21, 2023 4:31:04 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:04.186Z: Finished operation Write to
BQ/BatchLoads/FlattenFiles/Unzipped-1
Feb 21, 2023 4:31:04 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:04.350Z: Executing operation Write to
BQ/BatchLoads/ReifyResults/View.AsIterable/CreateDataflowView
Feb 21, 2023 4:31:04 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:04.414Z: Finished operation Write to
BQ/BatchLoads/ReifyResults/View.AsIterable/CreateDataflowView
Feb 21, 2023 4:31:04 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:04.542Z: Executing operation Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Create
Feb 21, 2023 4:31:04 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:04.580Z: Executing operation Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Create
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:04.710Z: Finished operation Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Create
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:04.746Z: Finished operation Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Create
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:04.911Z: Executing operation Write to
BQ/BatchLoads/ReifyResults/Create.Values/Read(CreateSource)+Write to
BQ/BatchLoads/ReifyResults/ParDo(Anonymous)+Write to
BQ/BatchLoads/WritePartitionUntriggered+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/Window.Into()/Window.Assign+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/Window.Into()/Window.Assign+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Reify+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Write+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Reify+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Write
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:05.597Z: Finished operation Write to
BQ/BatchLoads/ReifyResults/Create.Values/Read(CreateSource)+Write to
BQ/BatchLoads/ReifyResults/ParDo(Anonymous)+Write to
BQ/BatchLoads/WritePartitionUntriggered+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/Window.Into()/Window.Assign+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/Window.Into()/Window.Assign+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Reify+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Write+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Reify+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Write
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:05.677Z: Executing operation Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Close
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:05.738Z: Executing operation Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Close
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:05.757Z: Finished operation Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Close
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:05.785Z: Finished operation Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Close
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:05.827Z: Executing operation Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Create
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:05.860Z: Executing operation Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Create
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:05.954Z: Finished operation Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Create
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:06.008Z: Finished operation Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Create
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:06.089Z: Executing operation Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Read+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/GroupByWindow+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/ExpandIterable+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/ParMultiDo(WriteTables)+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/WithKeys/AddKeys/Map+Write to
BQ/BatchLoads/ReifyRenameInput/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+Write
to BQ/BatchLoads/MultiPartitionsWriteTables/Window.Into()/Window.Assign+Write
to BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Reify+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Write
Feb 21, 2023 4:31:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:06.124Z: Executing operation Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Read+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/GroupByWindow+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/ExpandIterable+Write to
BQ/BatchLoads/SinglePartitionWriteTables/ParMultiDo(WriteTables)+Write to
BQ/BatchLoads/SinglePartitionWriteTables/WithKeys/AddKeys/Map+Write to
BQ/BatchLoads/Keys/Keys/Map+Write to
BQ/BatchLoads/SinglePartitionWriteTables/Window.Into()/Window.Assign+Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Reify+Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Write+Write to
BQ/BatchLoads/Convert to TableDestinations
Feb 21, 2023 4:31:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:07.267Z: Finished operation Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Read+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/GroupByKey/GroupByWindow+Write to
BQ/BatchLoads/MultiPartitionsReshuffle/ExpandIterable+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/ParMultiDo(WriteTables)+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/WithKeys/AddKeys/Map+Write to
BQ/BatchLoads/ReifyRenameInput/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+Write
to BQ/BatchLoads/MultiPartitionsWriteTables/Window.Into()/Window.Assign+Write
to BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Reify+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Write
Feb 21, 2023 4:31:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:07.370Z: Executing operation Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Close
Feb 21, 2023 4:31:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:07.404Z: Executing operation Write to
BQ/BatchLoads/ReifyRenameInput/View.AsIterable/CreateDataflowView
Feb 21, 2023 4:31:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:07.424Z: Finished operation Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Close
Feb 21, 2023 4:31:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:07.456Z: Finished operation Write to
BQ/BatchLoads/ReifyRenameInput/View.AsIterable/CreateDataflowView
Feb 21, 2023 4:31:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:07.481Z: Executing operation Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Read+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/GroupByWindow+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/Values/Values/Map+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/ParDo(GarbageCollectTemporaryFiles)
Feb 21, 2023 4:31:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:07.581Z: Executing operation Write to
BQ/BatchLoads/ReifyRenameInput/Create.Values/Read(CreateSource)+Write to
BQ/BatchLoads/ReifyRenameInput/ParDo(Anonymous)+Write to
BQ/BatchLoads/ParDo(UpdateSchemaDestination)+Write to
BQ/BatchLoads/WriteRenameUntriggered
Feb 21, 2023 4:31:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:07.678Z: Finished operation Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Read+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/GroupByKey/GroupByWindow+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/Values/Values/Map+Write to
BQ/BatchLoads/MultiPartitionsWriteTables/ParDo(GarbageCollectTemporaryFiles)
Feb 21, 2023 4:31:12 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:09.918Z: Finished operation Write to
BQ/BatchLoads/ReifyRenameInput/Create.Values/Read(CreateSource)+Write to
BQ/BatchLoads/ReifyRenameInput/ParDo(Anonymous)+Write to
BQ/BatchLoads/ParDo(UpdateSchemaDestination)+Write to
BQ/BatchLoads/WriteRenameUntriggered
Feb 21, 2023 4:31:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:23.718Z: Finished operation Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Read+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/GroupByKey/GroupByWindow+Write to
BQ/BatchLoads/SinglePartitionsReshuffle/ExpandIterable+Write to
BQ/BatchLoads/SinglePartitionWriteTables/ParMultiDo(WriteTables)+Write to
BQ/BatchLoads/SinglePartitionWriteTables/WithKeys/AddKeys/Map+Write to
BQ/BatchLoads/Keys/Keys/Map+Write to
BQ/BatchLoads/SinglePartitionWriteTables/Window.Into()/Window.Assign+Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Reify+Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Write+Write to
BQ/BatchLoads/Convert to TableDestinations
Feb 21, 2023 4:31:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:23.819Z: Executing operation Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Close
Feb 21, 2023 4:31:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:23.854Z: Executing operation Write to
BQ/BatchLoads/Flatten.PCollections
Feb 21, 2023 4:31:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:23.946Z: Finished operation Write to
BQ/BatchLoads/Flatten.PCollections
Feb 21, 2023 4:31:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:24.563Z: Finished operation Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Close
Feb 21, 2023 4:31:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:24.639Z: Executing operation Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Read+Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/GroupByWindow+Write to
BQ/BatchLoads/SinglePartitionWriteTables/Values/Values/Map+Write to
BQ/BatchLoads/SinglePartitionWriteTables/ParDo(GarbageCollectTemporaryFiles)
Feb 21, 2023 4:31:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:25.859Z: Finished operation Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/Read+Write to
BQ/BatchLoads/SinglePartitionWriteTables/GroupByKey/GroupByWindow+Write to
BQ/BatchLoads/SinglePartitionWriteTables/Values/Values/Map+Write to
BQ/BatchLoads/SinglePartitionWriteTables/ParDo(GarbageCollectTemporaryFiles)
Feb 21, 2023 4:31:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:26.007Z: Cleaning up.
Feb 21, 2023 4:31:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2023-02-21T16:31:26.086Z: Stopping **** pool...
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-15' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
at com.sun.proxy.$Proxy143.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:317)
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: Pipe closed after 0 cycles
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:126)
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:105)
at
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:94)
at
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:75)
at
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:105)
at
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
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-15 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
