See
<https://ci-beam.apache.org/job/beam_PerformanceTests_JDBC/6097/display/redirect>
Changes:
------------------------------------------
[...truncated 332.27 KB...]
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:17.990Z: Fusing consumer
PAssert$4/GroupGlobally/ParDo(Concat) into
PAssert$4/GroupGlobally/Values/Values/Map
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.014Z: Fusing consumer PAssert$4/GetPane/Map into
PAssert$4/GroupGlobally/ParDo(Concat)
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.048Z: Fusing consumer PAssert$4/RunChecks into
PAssert$4/GetPane/Map
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.071Z: Fusing consumer
PAssert$4/VerifyAssertions/ParDo(DefaultConclude) into PAssert$4/RunChecks
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.094Z: Unzipping flatten s25-u121 for input
s27.org.apache.beam.sdk.values.PCollection.<init>:408#e89c9468260b066b-c119
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.128Z: Fusing unzipped copy of
PAssert$1/GroupGlobally/GroupByKey/Reify, through flatten
PAssert$1/GroupGlobally/Flatten.PCollections/Unzipped-1, into producer
PAssert$1/GroupGlobally/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.163Z: Unzipping flatten s63-u126 for input
s65.org.apache.beam.sdk.values.PCollection.<init>:408#b69a1bbb3a465604-c124
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.193Z: Fusing unzipped copy of
PAssert$3/GroupGlobally/GroupByKey/Reify, through flatten
PAssert$3/GroupGlobally/Flatten.PCollections/Unzipped-1, into producer
PAssert$3/GroupGlobally/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.220Z: Unzipping flatten s84-u131 for input
s86.org.apache.beam.sdk.values.PCollection.<init>:408#12c9b9612ce5396c-c129
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.246Z: Fusing unzipped copy of
PAssert$4/GroupGlobally/GroupByKey/Reify, through flatten
PAssert$4/GroupGlobally/Flatten.PCollections/Unzipped-1, into producer
PAssert$4/GroupGlobally/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.278Z: Unzipping flatten s21-u136 for input
s22.org.apache.beam.sdk.values.PCollection.<init>:408#f0f805bd79288b-c134
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.311Z: Fusing unzipped copy of
PAssert$1/GroupGlobally/ParDo(ToSingletonIterables), through flatten Count
All/Flatten.PCollections/Unzipped-1, into producer
PAssert$1/GroupGlobally/Reify.Window/ParDo(Anonymous)
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.334Z: Unzipping flatten s59-u141 for input
s60.org.apache.beam.sdk.values.PCollection.<init>:408#d15dcc46f84f5c2a-c139
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.369Z: Fusing unzipped copy of
PAssert$3/GroupGlobally/ParDo(ToSingletonIterables), through flatten
Combine.globally(Top(Reversed))/Flatten.PCollections/Unzipped-1, into producer
PAssert$3/GroupGlobally/Reify.Window/ParDo(Anonymous)
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.405Z: Unzipping flatten s80-u146 for input
s81.org.apache.beam.sdk.values.PCollection.<init>:408#c22b25ea2180c33a-c144
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.437Z: Fusing unzipped copy of
PAssert$4/GroupGlobally/ParDo(ToSingletonIterables), through flatten
Combine.globally(Top(Natural))/Flatten.PCollections/Unzipped-1, into producer
PAssert$4/GroupGlobally/Reify.Window/ParDo(Anonymous)
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.461Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Consume/ParDo(Anonymous) into
JdbcIO.Read/JdbcIO.ReadAll/ParDo(Read)
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.494Z: Fusing consumer Count
All/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow) into Count
All/Values/Values/Map
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.546Z: Fusing consumer
Combine.globally(Top(Reversed))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
into Combine.globally(Top(Reversed))/Values/Values/Map
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.579Z: Fusing consumer
Combine.globally(Top(Natural))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
into Combine.globally(Top(Natural))/Values/Values/Map
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.613Z: Fusing consumer
PAssert$1/GroupGlobally/Reify.Window/ParDo(Anonymous) into Count
All/ProduceDefault
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.637Z: Fusing consumer
PAssert$3/GroupGlobally/Reify.Window/ParDo(Anonymous) into
Combine.globally(Top(Reversed))/ProduceDefault
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.671Z: Fusing consumer
PAssert$4/GroupGlobally/Reify.Window/ParDo(Anonymous) into
Combine.globally(Top(Natural))/ProduceDefault
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.693Z: Fusing consumer
PAssert$1/GroupGlobally/ParDo(ToSingletonIterables) into
PAssert$1/GroupGlobally/Reify.Window/ParDo(Anonymous)
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.739Z: Fusing consumer
PAssert$3/GroupGlobally/ParDo(ToSingletonIterables) into
PAssert$3/GroupGlobally/Reify.Window/ParDo(Anonymous)
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.778Z: Fusing consumer
PAssert$4/GroupGlobally/ParDo(ToSingletonIterables) into
PAssert$4/GroupGlobally/Reify.Window/ParDo(Anonymous)
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.825Z: Unzipping flatten s42 for input
s40.org.apache.beam.sdk.values.PCollection.<init>:408#9b773e2b7b4947ac
Feb 28, 2022 12:25:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.858Z: Fusing unzipped copy of
PAssert$2/GroupGlobally/WithKeys/AddKeys/Map, through flatten
PAssert$2/GroupGlobally/Flatten.PCollections, into producer
PAssert$2/GroupGlobally/ParDo(ToSingletonIterables)
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.900Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/ParDo(Read) into
JdbcIO.Read/Create.Values/Read(CreateSource)
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.929Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
into JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Consume/ParDo(Anonymous)
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.953Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Pair
with random key into JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Identity
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:18.977Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
into
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Pair
with random key
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.012Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
into
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.043Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
into
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.079Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
into
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.123Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
into
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.202Z: Fusing consumer
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Values/Values/Map
into
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.265Z: Fusing consumer ParDo(TimeMonitor) into
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Values/Values/Map
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.315Z: Fusing consumer Count
All/Combine.perKey(Count)/GroupByKey+Count
All/Combine.perKey(Count)/Combine.GroupedValues/Partial into Count
All/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.370Z: Fusing consumer Count
All/Combine.perKey(Count)/GroupByKey/Reify into Count
All/Combine.perKey(Count)/GroupByKey+Count
All/Combine.perKey(Count)/Combine.GroupedValues/Partial
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.476Z: Fusing consumer Hash row
contents/WithKeys/AddKeys/Map into ParDo(SelectName)
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.542Z: Fusing consumer Hash row
contents/Combine.perKey(Hashing)/GroupByKey+Hash row
contents/Combine.perKey(Hashing)/Combine.GroupedValues/Partial into Hash row
contents/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.590Z: Fusing consumer Hash row
contents/Combine.perKey(Hashing)/GroupByKey/Reify into Hash row
contents/Combine.perKey(Hashing)/GroupByKey+Hash row
contents/Combine.perKey(Hashing)/Combine.GroupedValues/Partial
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.666Z: Fusing consumer
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Partial
into Combine.globally(Top(Reversed))/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.730Z: Fusing consumer
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Reify
into
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Partial
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.790Z: Fusing consumer
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Partial
into Combine.globally(Top(Natural))/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.835Z: Fusing consumer
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Reify
into
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Partial
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.870Z: Fusing consumer Count
All/Combine.perKey(Count)/GroupByKey/Write into Count
All/Combine.perKey(Count)/GroupByKey/Reify
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.916Z: Fusing consumer Count
All/Combine.perKey(Count)/Combine.GroupedValues into Count
All/Combine.perKey(Count)/GroupByKey/Read
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.953Z: Fusing consumer Count
All/Combine.perKey(Count)/Combine.GroupedValues/Extract into Count
All/Combine.perKey(Count)/Combine.GroupedValues
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:19.985Z: Fusing consumer Count All/Values/Values/Map
into Count All/Combine.perKey(Count)/Combine.GroupedValues/Extract
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.022Z: Fusing consumer Count All/ProduceDefault
into Count All/CreateVoid/Read(CreateSource)
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.055Z: Fusing consumer Hash row
contents/Combine.perKey(Hashing)/GroupByKey/Write into Hash row
contents/Combine.perKey(Hashing)/GroupByKey/Reify
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.088Z: Fusing consumer Hash row
contents/Combine.perKey(Hashing)/Combine.GroupedValues into Hash row
contents/Combine.perKey(Hashing)/GroupByKey/Read
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.123Z: Fusing consumer Hash row
contents/Combine.perKey(Hashing)/Combine.GroupedValues/Extract into Hash row
contents/Combine.perKey(Hashing)/Combine.GroupedValues
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.159Z: Fusing consumer Hash row
contents/Values/Values/Map into Hash row
contents/Combine.perKey(Hashing)/Combine.GroupedValues/Extract
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.194Z: Fusing consumer
PAssert$2/GroupGlobally/Reify.Window/ParDo(Anonymous) into Hash row
contents/Values/Values/Map
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.250Z: Fusing consumer
PAssert$2/GroupGlobally/ParDo(ToSingletonIterables) into
PAssert$2/GroupGlobally/Reify.Window/ParDo(Anonymous)
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.284Z: Fusing consumer
PAssert$2/GroupGlobally/GroupByKey/Write into
PAssert$2/GroupGlobally/GroupByKey/Reify
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.319Z: Fusing consumer
PAssert$2/GroupGlobally/GroupByKey/GroupByWindow into
PAssert$2/GroupGlobally/GroupByKey/Read
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.355Z: Fusing consumer
PAssert$2/GroupGlobally/Values/Values/Map into
PAssert$2/GroupGlobally/GroupByKey/GroupByWindow
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.388Z: Fusing consumer
PAssert$2/GroupGlobally/ParDo(Concat) into
PAssert$2/GroupGlobally/Values/Values/Map
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.421Z: Fusing consumer PAssert$2/GetPane/Map into
PAssert$2/GroupGlobally/ParDo(Concat)
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.446Z: Fusing consumer PAssert$2/RunChecks into
PAssert$2/GetPane/Map
Feb 28, 2022 12:25:20 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.481Z: Fusing consumer
PAssert$2/VerifyAssertions/ParDo(DefaultConclude) into PAssert$2/RunChecks
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.528Z: Fusing consumer
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Write
into
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Reify
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.565Z: Fusing consumer
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues
into
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Read
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.599Z: Fusing consumer
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Extract
into
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.630Z: Fusing consumer
Combine.globally(Top(Reversed))/Values/Values/Map into
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Extract
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.654Z: Fusing consumer
Combine.globally(Top(Reversed))/ProduceDefault into
Combine.globally(Top(Reversed))/CreateVoid/Read(CreateSource)
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.688Z: Fusing consumer
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Write
into
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Reify
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.723Z: Fusing consumer
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues
into
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Read
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.757Z: Fusing consumer
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Extract
into
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.779Z: Fusing consumer
Combine.globally(Top(Natural))/Values/Values/Map into
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Extract
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.802Z: Fusing consumer
Combine.globally(Top(Natural))/ProduceDefault into
Combine.globally(Top(Natural))/CreateVoid/Read(CreateSource)
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.827Z: Unzipping flatten s42-u187 for input
s44.org.apache.beam.sdk.values.PCollection.<init>:408#43d0369d0f0559b7-c185
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.851Z: 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
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.877Z: Fusing consumer
PAssert$1/GroupGlobally/WithKeys/AddKeys/Map into
PAssert$1/GroupGlobally/Create.Values/Read(CreateSource)
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.915Z: Fusing consumer
PAssert$3/GroupGlobally/WithKeys/AddKeys/Map into
PAssert$3/GroupGlobally/Create.Values/Read(CreateSource)
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.942Z: Fusing consumer
PAssert$4/GroupGlobally/WithKeys/AddKeys/Map into
PAssert$4/GroupGlobally/Create.Values/Read(CreateSource)
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:20.977Z: Fusing consumer
PAssert$2/GroupGlobally/WithKeys/AddKeys/Map into
PAssert$2/GroupGlobally/Create.Values/Read(CreateSource)
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:21.009Z: Fusing consumer
PAssert$1/GroupGlobally/GroupByKey/Reify into
PAssert$1/GroupGlobally/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:21.034Z: Fusing consumer
PAssert$3/GroupGlobally/GroupByKey/Reify into
PAssert$3/GroupGlobally/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:21.057Z: Fusing consumer
PAssert$4/GroupGlobally/GroupByKey/Reify into
PAssert$4/GroupGlobally/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:21.079Z: Fusing consumer
PAssert$2/GroupGlobally/GroupByKey/Reify into
PAssert$2/GroupGlobally/WithKeys/AddKeys/Map
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:21.454Z: 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)
Feb 28, 2022 12:25:22 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:21.547Z: Starting 5 ****s in us-central1-c...
Feb 28, 2022 12:25:27 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2022-02-28T12:25:25.478Z: 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
Feb 28, 2022 12:26:00 PM
org.apache.beam.runners.dataflow.DataflowPipelineJob lambda$waitUntilFinish$0
WARNING: Job is already running in Google Cloud Platform, Ctrl-C will not
cancel it.
To cancel the job in the cloud, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel
--region=us-central1 2022-02-28_04_25_01-6038870268612511962
org.apache.beam.sdk.io.jdbc.JdbcIOIT > testWriteThenRead SKIPPED
3 tests completed, 2 failed, 1 skipped
> Task :sdks:java:io:jdbc:integrationTest FAILED
:sdks:java:io:jdbc:integrationTest (Thread[Execution **** for ':' Thread
11,5,main]) completed. Took 6 mins 29.37 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:io:jdbc:integrationTest'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 143
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the User Manual at
https://docs.gradle.org/7.3.2/userguide/java_testing.html#sec:test_execution
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
BUILD FAILED in 6m 49s
129 actionable tasks: 75 executed, 52 from cache, 2 up-to-date
Publishing build scan...
The message received from the daemon indicates that the daemon has disappeared.
Build request sent: Build{id=5f5bf05a-1ecc-4b29-a594-ab6d7a518686,
currentDir=<https://ci-beam.apache.org/job/beam_PerformanceTests_JDBC/ws/src}>
Attempting to read last messages from the daemon log...
Daemon pid: 1310052
log file: /home/jenkins/.gradle/daemon/7.3.2/daemon-1310052.out.log
----- Last 20 lines from daemon log file - daemon-1310052.out.log -----
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:io:jdbc:integrationTest'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 143
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the User Manual at
https://docs.gradle.org/7.3.2/userguide/java_testing.html#sec:test_execution
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
BUILD FAILED in 6m 49s
129 actionable tasks: 75 executed, 52 from cache, 2 up-to-date
Publishing build scan...
Daemon vm is shutting down... The daemon has exited normally or was terminated
in response to a user interrupt.
----- End of the daemon log -----
FAILURE: Build failed with an exception.
* What went wrong:
Gradle build daemon disappeared unexpectedly (it may have been killed or may
have crashed)
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
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]
