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

Changes:

[noreply] Bump golang.org/x/text from 0.3.7 to 0.4.0 in /sdks (#23686)

[noreply] Unit Content markdown styles (#23592) (#23662)

[noreply] Add reopen issue command (#23733)

[noreply] Add example of real time Anomaly Detection using RunInference (#23497)

[noreply] Support TIMESTAMP type in BigQueryIO with BEAM_ROW output type, and in

[noreply] Add PytorchBatchConverter (#23296)

[noreply] Pin version to grpcio in build-requirements.txt (#23735)

[noreply] Bump up python container versions. (#23716)

[noreply] Reduce log flood in Python PostCommit flink task (#23635)


------------------------------------------
[...truncated 432.19 KB...]
    INFO: 2022-10-20T02:45:24.817Z: Fusing consumer 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues
 into 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Read
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:24.848Z: Fusing consumer 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Extract
 into 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:24.877Z: Fusing consumer 
Combine.globally(Top(Natural))/Values/Values/Map into 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Extract
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:24.907Z: Fusing consumer 
Combine.globally(Top(Natural))/ProduceDefault into 
Combine.globally(Top(Natural))/CreateVoid/Read(CreateSource)
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:24.933Z: Unzipping flatten s42-u187 for input 
s44.org.apache.beam.sdk.values.PCollection.<init>:405#6f48d10e0c26ced-c185
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:24.959Z: Fusing unzipped copy of 
PAssert$2/GroupGlobally/GroupByKey/Reify, through flatten 
PAssert$2/GroupGlobally/Flatten.PCollections/Unzipped-1, into producer 
PAssert$2/GroupGlobally/WithKeys/AddKeys/Map
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:24.993Z: Fusing consumer 
PAssert$1/GroupGlobally/WithKeys/AddKeys/Map into 
PAssert$1/GroupGlobally/Create.Values/Read(CreateSource)
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:25.023Z: Fusing consumer 
PAssert$3/GroupGlobally/WithKeys/AddKeys/Map into 
PAssert$3/GroupGlobally/Create.Values/Read(CreateSource)
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:25.055Z: Fusing consumer 
PAssert$4/GroupGlobally/WithKeys/AddKeys/Map into 
PAssert$4/GroupGlobally/Create.Values/Read(CreateSource)
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:25.078Z: Fusing consumer 
PAssert$2/GroupGlobally/WithKeys/AddKeys/Map into 
PAssert$2/GroupGlobally/Create.Values/Read(CreateSource)
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:25.105Z: Fusing consumer 
PAssert$1/GroupGlobally/GroupByKey/Reify into 
PAssert$1/GroupGlobally/WithKeys/AddKeys/Map
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:25.139Z: Fusing consumer 
PAssert$3/GroupGlobally/GroupByKey/Reify into 
PAssert$3/GroupGlobally/WithKeys/AddKeys/Map
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:25.163Z: Fusing consumer 
PAssert$4/GroupGlobally/GroupByKey/Reify into 
PAssert$4/GroupGlobally/WithKeys/AddKeys/Map
    Oct 20, 2022 2:45:25 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:25.187Z: Fusing consumer 
PAssert$2/GroupGlobally/GroupByKey/Reify into 
PAssert$2/GroupGlobally/WithKeys/AddKeys/Map
    Oct 20, 2022 2:45:27 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:25.635Z: Executing operation 
JdbcIO.Read/Create.Values/Read(CreateSource)+JdbcIO.Read/JdbcIO.ReadAll/ParDo(Read)+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Consume/ParDo(Anonymous)+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
    Oct 20, 2022 2:45:27 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:45:25.709Z: Starting 5 ****s in us-central1-f...
    Oct 20, 2022 2:46:06 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:46:04.200Z: Autoscaling: Raised the number of ****s to 
5 based on the rate of progress in the currently running stage(s).
    Oct 20, 2022 2:46:34 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:46:33.084Z: Workers have started successfully.
    Oct 20, 2022 2:47:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:47:31.329Z: Finished operation 
JdbcIO.Read/Create.Values/Read(CreateSource)+JdbcIO.Read/JdbcIO.ReadAll/ParDo(Read)+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Consume/ParDo(Anonymous)+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
    Oct 20, 2022 2:47:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:47:31.509Z: Executing operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/View.AsIterable/CreateDataflowView
    Oct 20, 2022 2:47:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:47:31.585Z: Finished operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/View.AsIterable/CreateDataflowView
    Oct 20, 2022 2:47:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:47:31.718Z: Executing operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
    Oct 20, 2022 2:47:34 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:47:32.016Z: Finished operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
    Oct 20, 2022 2:47:34 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:47:32.173Z: Executing operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Identity+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Pair
 with random 
key+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.171Z: Finished operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Identity+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Pair
 with random 
key+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.242Z: Executing operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.291Z: Finished operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.374Z: Executing operation 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Create
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.409Z: Executing operation Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Create
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.437Z: Executing operation 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Create
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.481Z: Executing operation Count 
All/Combine.perKey(Count)/GroupByKey/Create
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.551Z: Finished operation 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Create
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.556Z: Finished operation Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Create
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.588Z: Finished operation 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Create
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.648Z: Finished operation Count 
All/Combine.perKey(Count)/GroupByKey/Create
    Oct 20, 2022 2:48:01 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:00.813Z: Executing operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Values/Values/Map+ParDo(TimeMonitor)+Count
 
All/WithKeys/AddKeys/Map+ParDo(SelectName)+Combine.globally(Top(Reversed))/WithKeys/AddKeys/Map+Combine.globally(Top(Natural))/WithKeys/AddKeys/Map+Count
 All/Combine.perKey(Count)/GroupByKey+Count 
All/Combine.perKey(Count)/Combine.GroupedValues/Partial+Count 
All/Combine.perKey(Count)/GroupByKey/Reify+Hash row 
contents/WithKeys/AddKeys/Map+Hash row 
contents/Combine.perKey(Hashing)/GroupByKey+Hash row 
contents/Combine.perKey(Hashing)/Combine.GroupedValues/Partial+Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Reify+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Partial+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Reify+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Partial+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Reify+Count
 All/Combine.perKey(Count)/GroupByKey/Write+Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Write+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Write+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.543Z: Finished operation 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable+JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Values/Values/Map+ParDo(TimeMonitor)+Count
 
All/WithKeys/AddKeys/Map+ParDo(SelectName)+Combine.globally(Top(Reversed))/WithKeys/AddKeys/Map+Combine.globally(Top(Natural))/WithKeys/AddKeys/Map+Count
 All/Combine.perKey(Count)/GroupByKey+Count 
All/Combine.perKey(Count)/Combine.GroupedValues/Partial+Count 
All/Combine.perKey(Count)/GroupByKey/Reify+Hash row 
contents/WithKeys/AddKeys/Map+Hash row 
contents/Combine.perKey(Hashing)/GroupByKey+Hash row 
contents/Combine.perKey(Hashing)/Combine.GroupedValues/Partial+Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Reify+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Partial+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Reify+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Partial+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Reify+Count
 All/Combine.perKey(Count)/GroupByKey/Write+Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Write+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Write+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.614Z: Executing operation Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Close
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.655Z: Executing operation 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Close
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.670Z: Finished operation Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Close
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.700Z: Executing operation 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Close
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.717Z: Finished operation 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Close
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.733Z: Executing operation Count 
All/Combine.perKey(Count)/GroupByKey/Close
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.759Z: Finished operation 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Close
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.769Z: Executing operation 
PAssert$2/GroupGlobally/GroupByKey/Create
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.794Z: Finished operation Count 
All/Combine.perKey(Count)/GroupByKey/Close
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.801Z: Executing operation 
PAssert$3/GroupGlobally/GroupByKey/Create
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.827Z: Executing operation 
PAssert$4/GroupGlobally/GroupByKey/Create
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.863Z: Executing operation 
PAssert$1/GroupGlobally/GroupByKey/Create
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.926Z: Finished operation 
PAssert$2/GroupGlobally/GroupByKey/Create
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.954Z: Finished operation 
PAssert$3/GroupGlobally/GroupByKey/Create
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:27.976Z: Finished operation 
PAssert$4/GroupGlobally/GroupByKey/Create
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.020Z: Finished operation 
PAssert$1/GroupGlobally/GroupByKey/Create
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.093Z: Executing operation 
PAssert$2/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$2/GroupGlobally/WithKeys/AddKeys/Map+PAssert$2/GroupGlobally/GroupByKey/Reify+PAssert$2/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.125Z: Executing operation Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Read+Hash row 
contents/Combine.perKey(Hashing)/Combine.GroupedValues+Hash row 
contents/Combine.perKey(Hashing)/Combine.GroupedValues/Extract+Hash row 
contents/Values/Values/Map+PAssert$2/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$2/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$2/GroupGlobally/WithKeys/AddKeys/Map+PAssert$2/GroupGlobally/GroupByKey/Reify+PAssert$2/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.194Z: Executing operation 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Read+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Extract+Combine.globally(Top(Reversed))/Values/Values/Map+PAssert$3/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$3/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$3/GroupGlobally/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GroupByKey/Reify+PAssert$3/GroupGlobally/GroupByKey/Write+Combine.globally(Top(Reversed))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.220Z: Executing operation 
PAssert$3/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$3/GroupGlobally/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GroupByKey/Reify+PAssert$3/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.254Z: Executing operation 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Read+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Extract+Combine.globally(Top(Natural))/Values/Values/Map+PAssert$4/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$4/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$4/GroupGlobally/WithKeys/AddKeys/Map+PAssert$4/GroupGlobally/GroupByKey/Reify+PAssert$4/GroupGlobally/GroupByKey/Write+Combine.globally(Top(Natural))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.286Z: Executing operation 
PAssert$4/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$4/GroupGlobally/WithKeys/AddKeys/Map+PAssert$4/GroupGlobally/GroupByKey/Reify+PAssert$4/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.318Z: Executing operation Count 
All/Combine.perKey(Count)/GroupByKey/Read+Count 
All/Combine.perKey(Count)/Combine.GroupedValues+Count 
All/Combine.perKey(Count)/Combine.GroupedValues/Extract+Count 
All/Values/Values/Map+PAssert$1/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$1/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$1/GroupGlobally/WithKeys/AddKeys/Map+PAssert$1/GroupGlobally/GroupByKey/Reify+PAssert$1/GroupGlobally/GroupByKey/Write+Count
 All/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.350Z: Executing operation 
PAssert$1/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$1/GroupGlobally/WithKeys/AddKeys/Map+PAssert$1/GroupGlobally/GroupByKey/Reify+PAssert$1/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.458Z: Finished operation 
PAssert$3/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$3/GroupGlobally/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GroupByKey/Reify+PAssert$3/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.483Z: Finished operation Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Read+Hash row 
contents/Combine.perKey(Hashing)/Combine.GroupedValues+Hash row 
contents/Combine.perKey(Hashing)/Combine.GroupedValues/Extract+Hash row 
contents/Values/Values/Map+PAssert$2/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$2/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$2/GroupGlobally/WithKeys/AddKeys/Map+PAssert$2/GroupGlobally/GroupByKey/Reify+PAssert$2/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.514Z: Finished operation 
PAssert$4/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$4/GroupGlobally/WithKeys/AddKeys/Map+PAssert$4/GroupGlobally/GroupByKey/Reify+PAssert$4/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:28.543Z: Finished operation 
PAssert$1/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$1/GroupGlobally/WithKeys/AddKeys/Map+PAssert$1/GroupGlobally/GroupByKey/Reify+PAssert$1/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:29 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.316Z: Finished operation 
PAssert$2/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$2/GroupGlobally/WithKeys/AddKeys/Map+PAssert$2/GroupGlobally/GroupByKey/Reify+PAssert$2/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.382Z: Executing operation 
PAssert$2/GroupGlobally/GroupByKey/Close
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.444Z: Finished operation 
PAssert$2/GroupGlobally/GroupByKey/Close
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.512Z: Executing operation 
PAssert$2/GroupGlobally/GroupByKey/Read+PAssert$2/GroupGlobally/GroupByKey/GroupByWindow+PAssert$2/GroupGlobally/Values/Values/Map+PAssert$2/GroupGlobally/ParDo(Concat)+PAssert$2/GetPane/Map+PAssert$2/RunChecks+PAssert$2/VerifyAssertions/ParDo(DefaultConclude)
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.595Z: Finished operation Count 
All/Combine.perKey(Count)/GroupByKey/Read+Count 
All/Combine.perKey(Count)/Combine.GroupedValues+Count 
All/Combine.perKey(Count)/Combine.GroupedValues/Extract+Count 
All/Values/Values/Map+PAssert$1/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$1/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$1/GroupGlobally/WithKeys/AddKeys/Map+PAssert$1/GroupGlobally/GroupByKey/Reify+PAssert$1/GroupGlobally/GroupByKey/Write+Count
 All/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.741Z: Executing operation Count 
All/View.AsIterable/CreateDataflowView
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.787Z: Finished operation Count 
All/View.AsIterable/CreateDataflowView
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.863Z: Finished operation 
PAssert$2/GroupGlobally/GroupByKey/Read+PAssert$2/GroupGlobally/GroupByKey/GroupByWindow+PAssert$2/GroupGlobally/Values/Values/Map+PAssert$2/GroupGlobally/ParDo(Concat)+PAssert$2/GetPane/Map+PAssert$2/RunChecks+PAssert$2/VerifyAssertions/ParDo(DefaultConclude)
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.872Z: Finished operation 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Read+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Extract+Combine.globally(Top(Reversed))/Values/Values/Map+PAssert$3/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$3/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$3/GroupGlobally/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GroupByKey/Reify+PAssert$3/GroupGlobally/GroupByKey/Write+Combine.globally(Top(Reversed))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:29.892Z: Executing operation Count 
All/CreateVoid/Read(CreateSource)+Count 
All/ProduceDefault+PAssert$1/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$1/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$1/GroupGlobally/WithKeys/AddKeys/Map+PAssert$1/GroupGlobally/GroupByKey/Reify+PAssert$1/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.021Z: Executing operation 
Combine.globally(Top(Reversed))/View.AsIterable/CreateDataflowView
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.077Z: Finished operation 
Combine.globally(Top(Reversed))/View.AsIterable/CreateDataflowView
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.095Z: Finished operation 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Read+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Extract+Combine.globally(Top(Natural))/Values/Values/Map+PAssert$4/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$4/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$4/GroupGlobally/WithKeys/AddKeys/Map+PAssert$4/GroupGlobally/GroupByKey/Reify+PAssert$4/GroupGlobally/GroupByKey/Write+Combine.globally(Top(Natural))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.247Z: Executing operation 
Combine.globally(Top(Reversed))/CreateVoid/Read(CreateSource)+Combine.globally(Top(Reversed))/ProduceDefault+PAssert$3/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$3/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$3/GroupGlobally/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GroupByKey/Reify+PAssert$3/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.282Z: Executing operation 
Combine.globally(Top(Natural))/View.AsIterable/CreateDataflowView
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.375Z: Finished operation Count 
All/CreateVoid/Read(CreateSource)+Count 
All/ProduceDefault+PAssert$1/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$1/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$1/GroupGlobally/WithKeys/AddKeys/Map+PAssert$1/GroupGlobally/GroupByKey/Reify+PAssert$1/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.429Z: Finished operation 
Combine.globally(Top(Natural))/View.AsIterable/CreateDataflowView
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.450Z: Executing operation 
PAssert$1/GroupGlobally/GroupByKey/Close
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.502Z: Finished operation 
PAssert$1/GroupGlobally/GroupByKey/Close
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.564Z: Executing operation 
PAssert$1/GroupGlobally/GroupByKey/Read+PAssert$1/GroupGlobally/GroupByKey/GroupByWindow+PAssert$1/GroupGlobally/Values/Values/Map+PAssert$1/GroupGlobally/ParDo(Concat)+PAssert$1/GetPane/Map+PAssert$1/RunChecks+PAssert$1/VerifyAssertions/ParDo(DefaultConclude)
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.605Z: Executing operation 
Combine.globally(Top(Natural))/CreateVoid/Read(CreateSource)+Combine.globally(Top(Natural))/ProduceDefault+PAssert$4/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$4/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$4/GroupGlobally/WithKeys/AddKeys/Map+PAssert$4/GroupGlobally/GroupByKey/Reify+PAssert$4/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.665Z: Finished operation 
Combine.globally(Top(Reversed))/CreateVoid/Read(CreateSource)+Combine.globally(Top(Reversed))/ProduceDefault+PAssert$3/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$3/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$3/GroupGlobally/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GroupByKey/Reify+PAssert$3/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.727Z: Executing operation 
PAssert$3/GroupGlobally/GroupByKey/Close
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.786Z: Finished operation 
PAssert$3/GroupGlobally/GroupByKey/Close
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.812Z: Finished operation 
PAssert$1/GroupGlobally/GroupByKey/Read+PAssert$1/GroupGlobally/GroupByKey/GroupByWindow+PAssert$1/GroupGlobally/Values/Values/Map+PAssert$1/GroupGlobally/ParDo(Concat)+PAssert$1/GetPane/Map+PAssert$1/RunChecks+PAssert$1/VerifyAssertions/ParDo(DefaultConclude)
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:30.851Z: Executing operation 
PAssert$3/GroupGlobally/GroupByKey/Read+PAssert$3/GroupGlobally/GroupByKey/GroupByWindow+PAssert$3/GroupGlobally/Values/Values/Map+PAssert$3/GroupGlobally/ParDo(Concat)+PAssert$3/GetPane/Map+PAssert$3/RunChecks+PAssert$3/VerifyAssertions/ParDo(DefaultConclude)
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:31.142Z: Finished operation 
PAssert$3/GroupGlobally/GroupByKey/Read+PAssert$3/GroupGlobally/GroupByKey/GroupByWindow+PAssert$3/GroupGlobally/Values/Values/Map+PAssert$3/GroupGlobally/ParDo(Concat)+PAssert$3/GetPane/Map+PAssert$3/RunChecks+PAssert$3/VerifyAssertions/ParDo(DefaultConclude)
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:31.181Z: Finished operation 
Combine.globally(Top(Natural))/CreateVoid/Read(CreateSource)+Combine.globally(Top(Natural))/ProduceDefault+PAssert$4/GroupGlobally/Reify.Window/ParDo(Anonymous)+PAssert$4/GroupGlobally/ParDo(ToSingletonIterables)+PAssert$4/GroupGlobally/WithKeys/AddKeys/Map+PAssert$4/GroupGlobally/GroupByKey/Reify+PAssert$4/GroupGlobally/GroupByKey/Write
    Oct 20, 2022 2:48:31 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:31.247Z: Executing operation 
PAssert$4/GroupGlobally/GroupByKey/Close
    Oct 20, 2022 2:48:33 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:31.297Z: Finished operation 
PAssert$4/GroupGlobally/GroupByKey/Close
    Oct 20, 2022 2:48:33 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:31.367Z: Executing operation 
PAssert$4/GroupGlobally/GroupByKey/Read+PAssert$4/GroupGlobally/GroupByKey/GroupByWindow+PAssert$4/GroupGlobally/Values/Values/Map+PAssert$4/GroupGlobally/ParDo(Concat)+PAssert$4/GetPane/Map+PAssert$4/RunChecks+PAssert$4/VerifyAssertions/ParDo(DefaultConclude)
    Oct 20, 2022 2:48:33 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:31.673Z: Finished operation 
PAssert$4/GroupGlobally/GroupByKey/Read+PAssert$4/GroupGlobally/GroupByKey/GroupByWindow+PAssert$4/GroupGlobally/Values/Values/Map+PAssert$4/GroupGlobally/ParDo(Concat)+PAssert$4/GetPane/Map+PAssert$4/RunChecks+PAssert$4/VerifyAssertions/ParDo(DefaultConclude)
    Oct 20, 2022 2:48:35 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:34.145Z: Cleaning up.
    Oct 20, 2022 2:48:35 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:48:34.226Z: Stopping **** pool...
    Oct 20, 2022 2:49:19 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:49:19.018Z: Autoscaling: Resized **** pool from 5 to 0.
    Oct 20, 2022 2:49:19 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-10-20T02:49:19.074Z: Worker pool stopped.
    Oct 20, 2022 2:49:28 AM 
org.apache.beam.runners.dataflow.DataflowPipelineJob logTerminalState
    INFO: Job 2022-10-19_19_45_07-2044123752375580712 finished with status DONE.

org.apache.beam.sdk.io.jdbc.JdbcIOIT > testWriteThenRead STANDARD_OUT
    Load test results for test (ID): 0ce2a706-0ea9-40dc-8807-b7bb7fc4589b and 
timestamp: 2022-10-20T02:49:28.885000000Z:
                     Metric:                    Value:
                  total_size              2.60841472E8
                  write_time                    42.558
    Load test results for test (ID): 0ce2a706-0ea9-40dc-8807-b7bb7fc4589b and 
timestamp: 2022-10-20T02:49:28.885000000Z:
                     Metric:                    Value:
                   read_time                    25.915

Gradle Test Executor 1 finished executing tests.

> Task :sdks:java:io:jdbc:integrationTest FAILED

3 tests completed, 1 failed
Finished generating test XML results (0.029 secs) into: 
<https://ci-beam.apache.org/job/beam_PerformanceTests_JDBC/ws/src/sdks/java/io/jdbc/build/test-results/integrationTest>
Generating HTML test report...
Finished generating test html results (0.034 secs) into: 
<https://ci-beam.apache.org/job/beam_PerformanceTests_JDBC/ws/src/sdks/java/io/jdbc/build/reports/tests/integrationTest>
:sdks:java:io:jdbc:integrationTest (Thread[Execution **** Thread 6,5,main]) 
completed. Took 40 mins 55.262 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':sdks:java:io:jdbc:integrationTest'.
> There were failing tests. See the report at: 
> file://<https://ci-beam.apache.org/job/beam_PerformanceTests_JDBC/ws/src/sdks/java/io/jdbc/build/reports/tests/integrationTest/index.html>

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --debug option to get more log output.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 8.0.

You can use '--warning-mode all' to show the individual deprecation warnings 
and determine if they come from your own scripts or plugins.

See 
https://docs.gradle.org/7.5.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 41m 24s
135 actionable tasks: 80 executed, 53 from cache, 2 up-to-date

Publishing build scan...
https://gradle.com/s/bghtd2ie5juri

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]


Reply via email to