See
<https://builds.apache.org/job/beam_PerformanceTests_JDBC/3438/display/redirect?page=changes>
Changes:
[mxm] [BEAM-9794] Reduce state cells needed for BufferingDoFnRunner
[github] [BEAM-9701] Increments fastavro version range upper bound to 0.24.
------------------------------------------
[...truncated 417.29 KB...]
at org.postgresql.Driver.makeConnection(Driver.java:452)
at org.postgresql.Driver.connect(Driver.java:254)
at java.sql.DriverManager.getConnection(DriverManager.java:664)
at java.sql.DriverManager.getConnection(DriverManager.java:247)
at
org.postgresql.ds.common.BaseDataSource.getConnection(BaseDataSource.java:94)
at
org.postgresql.ds.common.BaseDataSource.getConnection(BaseDataSource.java:79)
at org.apache.beam.sdk.io.jdbc.JdbcIO$ReadFn.setup(JdbcIO.java:882)
at
org.apache.beam.sdk.io.jdbc.JdbcIO$ReadFn$DoFnInvoker.invokeSetup(Unknown
Source)
at
org.apache.beam.runners.dataflow.worker.DoFnInstanceManagers$ConcurrentQueueInstanceManager.deserializeCopy(DoFnInstanceManagers.java:80)
at
org.apache.beam.runners.dataflow.worker.DoFnInstanceManagers$ConcurrentQueueInstanceManager.peek(DoFnInstanceManagers.java:62)
at
org.apache.beam.runners.dataflow.worker.UserParDoFnFactory.create(UserParDoFnFactory.java:95)
at
org.apache.beam.runners.dataflow.worker.DefaultParDoFnFactory.create(DefaultParDoFnFactory.java:75)
at
org.apache.beam.runners.dataflow.worker.IntrinsicMapTaskExecutorFactory.createParDoOperation(IntrinsicMapTaskExecutorFactory.java:264)
at
org.apache.beam.runners.dataflow.worker.IntrinsicMapTaskExecutorFactory.access$000(IntrinsicMapTaskExecutorFactory.java:86)
at
org.apache.beam.runners.dataflow.worker.IntrinsicMapTaskExecutorFactory$1.typedApply(IntrinsicMapTaskExecutorFactory.java:183)
at
org.apache.beam.runners.dataflow.worker.IntrinsicMapTaskExecutorFactory$1.typedApply(IntrinsicMapTaskExecutorFactory.java:165)
at
org.apache.beam.runners.dataflow.worker.graph.Networks$TypeSafeNodeFunction.apply(Networks.java:63)
at
org.apache.beam.runners.dataflow.worker.graph.Networks$TypeSafeNodeFunction.apply(Networks.java:50)
at
org.apache.beam.runners.dataflow.worker.graph.Networks.replaceDirectedNetworkNodes(Networks.java:87)
at
org.apache.beam.runners.dataflow.worker.IntrinsicMapTaskExecutorFactory.create(IntrinsicMapTaskExecutorFactory.java:125)
at
org.apache.beam.runners.dataflow.worker.BatchDataflowWorker.doWork(BatchDataflowWorker.java:358)
at
org.apache.beam.runners.dataflow.worker.BatchDataflowWorker.getAndPerformWork(BatchDataflowWorker.java:311)
at
org.apache.beam.runners.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.doWork(DataflowBatchWorkerHarness.java:140)
at
org.apache.beam.runners.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:120)
at
org.apache.beam.runners.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:107)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Apr 23, 2020 6:33:41 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:33:41.065Z: 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)
Apr 23, 2020 6:33:41 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:33:41.281Z: Executing operation
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/View.AsIterable/CreateDataflowView
Apr 23, 2020 6:33:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:33:41.376Z: Finished operation
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/View.AsIterable/CreateDataflowView
Apr 23, 2020 6:33:42 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:33:41.550Z: 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
Apr 23, 2020 6:34:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:23.860Z: 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
Apr 23, 2020 6:34:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:23.945Z: Executing operation
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Apr 23, 2020 6:34:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:24.029Z: Finished operation
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Apr 23, 2020 6:34:25 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:24.110Z: 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+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Write+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
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.079Z: 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+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Write+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
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.147Z: Executing operation Count
All/Combine.perKey(Count)/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.172Z: Executing operation Hash row
contents/Combine.perKey(Hashing)/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.207Z: Executing operation
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.216Z: Finished operation Count
All/Combine.perKey(Count)/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.237Z: Executing operation
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.245Z: Finished operation Hash row
contents/Combine.perKey(Hashing)/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.271Z: Finished operation
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.275Z: 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$0/GroupGlobally/Window.Into()/Window.Assign+PAssert$0/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$0/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Write+Count
All/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.301Z: Finished operation
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.310Z: 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$1/GroupGlobally/Window.Into()/Window.Assign+PAssert$1/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$1/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$1/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.341Z: 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$2/GroupGlobally/Window.Into()/Window.Assign+PAssert$2/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$2/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$2/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Write+Combine.globally(Top(Reversed))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.371Z: 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+Combine.globally(Top(Natural))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+PAssert$3/GroupGlobally/Window.Into()/Window.Assign+PAssert$3/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$3/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.708Z: 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$1/GroupGlobally/Window.Into()/Window.Assign+PAssert$1/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$1/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$1/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.780Z: Executing operation
PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.851Z: Finished operation
PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Apr 23, 2020 6:35:01 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:34:59.923Z: Executing operation
PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$1/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$1/GroupGlobally/RewindowActuals/Window.Assign+PAssert$1/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$1/GroupGlobally/GroupDummyAndContents/Reify+PAssert$1/GroupGlobally/GroupDummyAndContents/Write
Apr 23, 2020 6:35:02 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.501Z: 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$2/GroupGlobally/Window.Into()/Window.Assign+PAssert$2/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$2/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$2/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Write+Combine.globally(Top(Reversed))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
Apr 23, 2020 6:35:02 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.523Z: Finished operation
PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$1/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$1/GroupGlobally/RewindowActuals/Window.Assign+PAssert$1/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$1/GroupGlobally/GroupDummyAndContents/Reify+PAssert$1/GroupGlobally/GroupDummyAndContents/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.606Z: Executing operation
PAssert$1/GroupGlobally/GroupDummyAndContents/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.643Z: Executing operation
Combine.globally(Top(Reversed))/View.AsIterable/CreateDataflowView
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.661Z: Finished operation
PAssert$1/GroupGlobally/GroupDummyAndContents/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.700Z: Finished operation
Combine.globally(Top(Reversed))/View.AsIterable/CreateDataflowView
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.719Z: Executing operation
PAssert$1/GroupGlobally/GroupDummyAndContents/Read+PAssert$1/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$1/GroupGlobally/Values/Values/Map+PAssert$1/GroupGlobally/ParDo(Concat)+PAssert$1/GetPane/Map+PAssert$1/RunChecks+PAssert$1/VerifyAssertions/ParDo(DefaultConclude)
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.792Z: 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+Combine.globally(Top(Natural))/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+PAssert$3/GroupGlobally/Window.Into()/Window.Assign+PAssert$3/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$3/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.840Z: Executing operation
Combine.globally(Top(Reversed))/CreateVoid/Read(CreateSource)+Combine.globally(Top(Reversed))/ProduceDefault+PAssert$2/GroupGlobally/Window.Into()/Window.Assign+PAssert$2/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$2/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$2/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.945Z: Executing operation
Combine.globally(Top(Natural))/View.AsIterable/CreateDataflowView
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:02.993Z: Finished operation
Combine.globally(Top(Natural))/View.AsIterable/CreateDataflowView
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.134Z: Executing operation
Combine.globally(Top(Natural))/CreateVoid/Read(CreateSource)+Combine.globally(Top(Natural))/ProduceDefault+PAssert$3/GroupGlobally/Window.Into()/Window.Assign+PAssert$3/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$3/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.184Z: Finished operation
PAssert$1/GroupGlobally/GroupDummyAndContents/Read+PAssert$1/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$1/GroupGlobally/Values/Values/Map+PAssert$1/GroupGlobally/ParDo(Concat)+PAssert$1/GetPane/Map+PAssert$1/RunChecks+PAssert$1/VerifyAssertions/ParDo(DefaultConclude)
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.572Z: Finished operation
Combine.globally(Top(Reversed))/CreateVoid/Read(CreateSource)+Combine.globally(Top(Reversed))/ProduceDefault+PAssert$2/GroupGlobally/Window.Into()/Window.Assign+PAssert$2/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$2/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$2/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.593Z: 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$0/GroupGlobally/Window.Into()/Window.Assign+PAssert$0/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$0/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Write+Count
All/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.631Z: Executing operation
PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.691Z: Finished operation
PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.737Z: Executing operation Count
All/View.AsIterable/CreateDataflowView
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.738Z: Finished operation
Combine.globally(Top(Natural))/CreateVoid/Read(CreateSource)+Combine.globally(Top(Natural))/ProduceDefault+PAssert$3/GroupGlobally/Window.Into()/Window.Assign+PAssert$3/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$3/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$3/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.769Z: Executing operation
PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$2/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$2/GroupGlobally/RewindowActuals/Window.Assign+PAssert$2/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$2/GroupGlobally/GroupDummyAndContents/Reify+PAssert$2/GroupGlobally/GroupDummyAndContents/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.789Z: Finished operation Count
All/View.AsIterable/CreateDataflowView
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.805Z: Executing operation
PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.894Z: Finished operation
PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:03.965Z: Executing operation Count
All/CreateVoid/Read(CreateSource)+Count
All/ProduceDefault+PAssert$0/GroupGlobally/Window.Into()/Window.Assign+PAssert$0/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$0/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.004Z: Executing operation
PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$3/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$3/GroupGlobally/RewindowActuals/Window.Assign+PAssert$3/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$3/GroupGlobally/GroupDummyAndContents/Reify+PAssert$3/GroupGlobally/GroupDummyAndContents/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.359Z: Finished operation
PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$3/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$3/GroupGlobally/RewindowActuals/Window.Assign+PAssert$3/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$3/GroupGlobally/GroupDummyAndContents/Reify+PAssert$3/GroupGlobally/GroupDummyAndContents/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.366Z: Finished operation
PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$2/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$2/GroupGlobally/RewindowActuals/Window.Assign+PAssert$2/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$2/GroupGlobally/GroupDummyAndContents/Reify+PAssert$2/GroupGlobally/GroupDummyAndContents/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.479Z: Executing operation
PAssert$3/GroupGlobally/GroupDummyAndContents/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.513Z: Executing operation
PAssert$2/GroupGlobally/GroupDummyAndContents/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.550Z: Finished operation
PAssert$3/GroupGlobally/GroupDummyAndContents/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.592Z: Finished operation
PAssert$2/GroupGlobally/GroupDummyAndContents/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.646Z: Executing operation
PAssert$3/GroupGlobally/GroupDummyAndContents/Read+PAssert$3/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$3/GroupGlobally/Values/Values/Map+PAssert$3/GroupGlobally/ParDo(Concat)+PAssert$3/GetPane/Map+PAssert$3/RunChecks+PAssert$3/VerifyAssertions/ParDo(DefaultConclude)
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.703Z: Executing operation
PAssert$2/GroupGlobally/GroupDummyAndContents/Read+PAssert$2/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$2/GroupGlobally/Values/Values/Map+PAssert$2/GroupGlobally/ParDo(Concat)+PAssert$2/GetPane/Map+PAssert$2/RunChecks+PAssert$2/VerifyAssertions/ParDo(DefaultConclude)
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.753Z: Finished operation Count
All/CreateVoid/Read(CreateSource)+Count
All/ProduceDefault+PAssert$0/GroupGlobally/Window.Into()/Window.Assign+PAssert$0/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$0/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$0/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.865Z: Executing operation
PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:04.955Z: Finished operation
PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:05.054Z: Executing operation
PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$0/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$0/GroupGlobally/RewindowActuals/Window.Assign+PAssert$0/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$0/GroupGlobally/GroupDummyAndContents/Reify+PAssert$0/GroupGlobally/GroupDummyAndContents/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:05.169Z: Finished operation
PAssert$3/GroupGlobally/GroupDummyAndContents/Read+PAssert$3/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$3/GroupGlobally/Values/Values/Map+PAssert$3/GroupGlobally/ParDo(Concat)+PAssert$3/GetPane/Map+PAssert$3/RunChecks+PAssert$3/VerifyAssertions/ParDo(DefaultConclude)
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:05.252Z: Finished operation
PAssert$2/GroupGlobally/GroupDummyAndContents/Read+PAssert$2/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$2/GroupGlobally/Values/Values/Map+PAssert$2/GroupGlobally/ParDo(Concat)+PAssert$2/GetPane/Map+PAssert$2/RunChecks+PAssert$2/VerifyAssertions/ParDo(DefaultConclude)
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:05.376Z: Finished operation
PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$0/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$0/GroupGlobally/RewindowActuals/Window.Assign+PAssert$0/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$0/GroupGlobally/GroupDummyAndContents/Reify+PAssert$0/GroupGlobally/GroupDummyAndContents/Write
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:05.464Z: Executing operation
PAssert$0/GroupGlobally/GroupDummyAndContents/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:05.536Z: Finished operation
PAssert$0/GroupGlobally/GroupDummyAndContents/Close
Apr 23, 2020 6:35:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:05.623Z: Executing operation
PAssert$0/GroupGlobally/GroupDummyAndContents/Read+PAssert$0/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$0/GroupGlobally/Values/Values/Map+PAssert$0/GroupGlobally/ParDo(Concat)+PAssert$0/GetPane/Map+PAssert$0/RunChecks+PAssert$0/VerifyAssertions/ParDo(DefaultConclude)
Apr 23, 2020 6:35:07 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:06.144Z: Finished operation
PAssert$0/GroupGlobally/GroupDummyAndContents/Read+PAssert$0/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$0/GroupGlobally/Values/Values/Map+PAssert$0/GroupGlobally/ParDo(Concat)+PAssert$0/GetPane/Map+PAssert$0/RunChecks+PAssert$0/VerifyAssertions/ParDo(DefaultConclude)
Apr 23, 2020 6:35:07 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:06.405Z: Cleaning up.
Apr 23, 2020 6:35:07 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:35:06.508Z: Stopping worker pool...
Apr 23, 2020 6:37:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:37:04.997Z: Autoscaling: Resized worker pool from 5 to
0.
Apr 23, 2020 6:37:06 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-04-23T18:37:05.051Z: Worker pool stopped.
Apr 23, 2020 6:37:13 PM
org.apache.beam.runners.dataflow.DataflowPipelineJob logTerminalState
INFO: Job 2020-04-23_11_30_44-7655044010720000107 finished with status DONE.
org.apache.beam.sdk.io.jdbc.JdbcIOIT > testWriteThenRead STANDARD_OUT
Load test results for test (ID): 1cc06c33-60e9-4b3e-8c4c-bf8877c54993 and
timestamp: 2020-04-23T18:37:13.931000000Z:
Metric: Value:
write_time 55.991
Load test results for test (ID): 1cc06c33-60e9-4b3e-8c4c-bf8877c54993 and
timestamp: 2020-04-23T18:37:13.931000000Z:
Metric: Value:
read_time 33.235
org.apache.beam.sdk.io.jdbc.JdbcIOIT STANDARD_ERROR
Apr 23, 2020 6:37:15 PM org.apache.beam.sdk.io.common.IOITHelper
executeWithRetry
WARNING: Attempt #1 of 3 failed: ERROR: table
"beamtest_it_2020_04_23_18_25_51_98" does not exist.
Apr 23, 2020 6:37:15 PM org.apache.beam.sdk.io.common.IOITHelper
executeWithRetry
WARNING: Retrying in 2000 ms.
Apr 23, 2020 6:37:17 PM org.apache.beam.sdk.io.common.IOITHelper
executeWithRetry
WARNING: Attempt #2 of 3 failed: ERROR: table
"beamtest_it_2020_04_23_18_25_51_98" does not exist.
Apr 23, 2020 6:37:17 PM org.apache.beam.sdk.io.common.IOITHelper
executeWithRetry
WARNING: Retrying in 4000 ms.
Apr 23, 2020 6:37:21 PM org.apache.beam.sdk.io.common.IOITHelper
executeWithRetry
WARNING: Attempt #3 of 3 failed: ERROR: table
"beamtest_it_2020_04_23_18_25_51_98" does not exist.
org.apache.beam.sdk.io.jdbc.JdbcIOIT > classMethod FAILED
org.postgresql.util.PSQLException: ERROR: table
"beamtest_it_2020_04_23_18_25_51_98" does not exist
at
org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2433)
at
org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2178)
at
org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:306)
at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:441)
at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:365)
at
org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:307)
at
org.postgresql.jdbc.PgStatement.executeCachedSql(PgStatement.java:293)
at
org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:270)
at org.postgresql.jdbc.PgStatement.executeUpdate(PgStatement.java:244)
at
org.apache.beam.sdk.io.common.DatabaseTestHelper.deleteTable(DatabaseTestHelper.java:65)
at org.apache.beam.sdk.io.jdbc.JdbcIOIT.deleteTable(JdbcIOIT.java:115)
at
org.apache.beam.sdk.io.common.IOITHelper.executeWithRetry(IOITHelper.java:86)
at
org.apache.beam.sdk.io.common.IOITHelper.executeWithRetry(IOITHelper.java:66)
at org.apache.beam.sdk.io.jdbc.JdbcIOIT.tearDown(JdbcIOIT.java:111)
Gradle Test Executor 1 finished executing tests.
> Task :sdks:java:io:jdbc:integrationTest FAILED
2 tests completed, 1 failed
Finished generating test XML results (0.025 secs) into:
<https://builds.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.042 secs) into:
<https://builds.apache.org/job/beam_PerformanceTests_JDBC/ws/src/sdks/java/io/jdbc/build/reports/tests/integrationTest>
:sdks:java:io:jdbc:integrationTest (Thread[Execution worker for ':' Thread
9,5,main]) completed. Took 11 mins 33.874 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://builds.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. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 12m 20s
81 actionable tasks: 52 executed, 29 from cache
Publishing build scan...
https://gradle.com/s/73tglzjpfafra
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]
