You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2020/03/07 00:57:29 UTC
Build failed in Jenkins: beam_PerformanceTests_JDBC #3248
See <https://builds.apache.org/job/beam_PerformanceTests_JDBC/3248/display/redirect?page=changes>
Changes:
[ehudm] Reduce warnings in pytest runs.
[robertwb] Remove excessive logging.
[lcwik] [BEAM-2939, BEAM-9458] Add deduplication transform for SplittableDoFns
------------------------------------------
[...truncated 334.90 KB...]
Mar 07, 2020 12:52:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:52:30.868Z: Executing operation Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Create
Mar 07, 2020 12:52:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:52:30.896Z: Finished operation PAssert$2/GroupGlobally/GroupDummyAndContents/Create
Mar 07, 2020 12:52:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:52:30.932Z: Finished operation Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Create
Mar 07, 2020 12:52:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:52:31.293Z: Executing operation PAssert$3/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$3/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$3/GroupGlobally/GroupDummyAndContents/Reify+PAssert$3/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 12:52:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:52:31.394Z: Executing operation PAssert$0/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$0/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$0/GroupGlobally/GroupDummyAndContents/Reify+PAssert$0/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 12:52:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:52:31.422Z: Executing operation PAssert$1/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$1/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$1/GroupGlobally/GroupDummyAndContents/Reify+PAssert$1/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 12:52:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:52:31.459Z: Executing operation PAssert$2/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$2/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$2/GroupGlobally/GroupDummyAndContents/Reify+PAssert$2/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 12:52:34 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2020-03-07T00:52:33.639Z: Your project already contains 100 Dataflow-created metric descriptors and Stackdriver will not create new Dataflow custom metrics for this job. Each unique user-defined metric name (independent of the DoFn in which it is defined) produces a new metric descriptor. To 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
Mar 07, 2020 12:52:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:52:54.357Z: Autoscaling: Raised the number of workers to 5 based on the rate of progress in the currently running step(s).
Mar 07, 2020 12:53:11 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:53:10.983Z: Workers have started successfully.
Mar 07, 2020 12:53:11 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:53:11.014Z: Workers have started successfully.
Mar 07, 2020 12:53:29 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:53:28.856Z: Finished operation PAssert$2/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$2/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$2/GroupGlobally/GroupDummyAndContents/Reify+PAssert$2/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 12:53:29 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:53:28.990Z: Finished operation PAssert$3/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$3/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$3/GroupGlobally/GroupDummyAndContents/Reify+PAssert$3/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 12:53:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:53:30.248Z: Finished operation PAssert$0/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$0/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$0/GroupGlobally/GroupDummyAndContents/Reify+PAssert$0/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 12:53:31 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:53:31.258Z: Finished operation PAssert$1/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$1/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$1/GroupGlobally/GroupDummyAndContents/Reify+PAssert$1/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 12:54:28 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:54:27.554Z: 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)
Mar 07, 2020 12:54:28 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:54:27.743Z: Executing operation JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/View.AsIterable/CreateDataflowView
Mar 07, 2020 12:54:28 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:54:27.800Z: Finished operation JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/View.AsIterable/CreateDataflowView
Mar 07, 2020 12:54:28 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:54:27.952Z: 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
Mar 07, 2020 12:55:10 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:09.451Z: 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
Mar 07, 2020 12:55:10 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:09.511Z: Executing operation JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Mar 07, 2020 12:55:10 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:09.561Z: Finished operation JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Mar 07, 2020 12:55:10 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:09.635Z: 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
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:45.608Z: 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
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:45.807Z: Executing operation Count All/Combine.perKey(Count)/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:45.876Z: Executing operation Hash row contents/Combine.perKey(Hashing)/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:45.937Z: Executing operation Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:45.984Z: Finished operation Count All/Combine.perKey(Count)/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:46.048Z: Executing operation Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:46.059Z: Finished operation Hash row contents/Combine.perKey(Hashing)/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:46.294Z: Finished operation Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:46.296Z: Finished operation Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:46.321Z: 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)
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:46.359Z: 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
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:46.393Z: 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)
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:46.422Z: 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
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:47.729Z: 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
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:47.792Z: Executing operation PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:47.842Z: Finished operation PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Mar 07, 2020 12:55:48 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:47.930Z: 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
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:49.900Z: 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
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:49.970Z: Executing operation PAssert$1/GroupGlobally/GroupDummyAndContents/Close
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.029Z: Finished operation PAssert$1/GroupGlobally/GroupDummyAndContents/Close
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.105Z: 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)
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.522Z: 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
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.555Z: 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)
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.634Z: 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)
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.682Z: Executing operation Combine.globally(Top(Natural))/View.AsIterable/CreateDataflowView
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.739Z: Finished operation Combine.globally(Top(Natural))/View.AsIterable/CreateDataflowView
Mar 07, 2020 12:55:50 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.796Z: Executing operation Combine.globally(Top(Reversed))/View.AsIterable/CreateDataflowView
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.841Z: Finished operation Combine.globally(Top(Reversed))/View.AsIterable/CreateDataflowView
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:50.893Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.000Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.044Z: 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)
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.184Z: Executing operation Count All/View.AsIterable/CreateDataflowView
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.294Z: Finished operation Count All/View.AsIterable/CreateDataflowView
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.424Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.453Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.522Z: Executing operation PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.548Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.582Z: Finished operation PAssert$3/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.605Z: Executing operation PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.654Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.663Z: Finished operation PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.725Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.880Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.925Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.963Z: Executing operation PAssert$3/GroupGlobally/GroupDummyAndContents/Close
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:51.981Z: 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
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.003Z: Executing operation PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Mar 07, 2020 12:55:52 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.023Z: Finished operation PAssert$3/GroupGlobally/GroupDummyAndContents/Close
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.047Z: Executing operation PAssert$2/GroupGlobally/GroupDummyAndContents/Close
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.053Z: Finished operation PAssert$0/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.080Z: 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)
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.102Z: Finished operation PAssert$2/GroupGlobally/GroupDummyAndContents/Close
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.113Z: 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
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.164Z: 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)
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.802Z: 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)
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:52.835Z: 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)
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:53.397Z: 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
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:53.469Z: Executing operation PAssert$0/GroupGlobally/GroupDummyAndContents/Close
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:53.528Z: Finished operation PAssert$0/GroupGlobally/GroupDummyAndContents/Close
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:53.601Z: 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)
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:53.940Z: 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)
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:54.145Z: Cleaning up.
Mar 07, 2020 12:55:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:55:54.238Z: Stopping worker pool...
Mar 07, 2020 12:57:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:57:12.531Z: Autoscaling: Resized worker pool from 5 to 0.
Mar 07, 2020 12:57:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T00:57:12.573Z: Worker pool stopped.
Mar 07, 2020 12:57:17 AM org.apache.beam.runners.dataflow.DataflowPipelineJob logTerminalState
INFO: Job 2020-03-06_16_52_10-1915248197512124786 finished with status DONE.
org.apache.beam.sdk.io.jdbc.JdbcIOIT > testWriteThenRead STANDARD_OUT
Load test results for test (ID): 74814801-5d6e-4ea3-821d-e488ff4ffc60 and timestamp: 2020-03-07T00:57:17.743000000Z:
Metric: Value:
write_time 195.717
Load test results for test (ID): 74814801-5d6e-4ea3-821d-e488ff4ffc60 and timestamp: 2020-03-07T00:57:17.743000000Z:
Metric: Value:
read_time 34.914
org.apache.beam.sdk.io.jdbc.JdbcIOIT STANDARD_ERROR
Mar 07, 2020 12:57:18 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Attempt #1 of 3 failed: ERROR: table "beamtest_it_2020_03_07_00_46_04_167" does not exist.
Mar 07, 2020 12:57:18 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Retrying in 2000 ms.
Mar 07, 2020 12:57:20 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Attempt #2 of 3 failed: ERROR: table "beamtest_it_2020_03_07_00_46_04_167" does not exist.
Mar 07, 2020 12:57:20 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Retrying in 4000 ms.
Mar 07, 2020 12:57:24 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Attempt #3 of 3 failed: ERROR: table "beamtest_it_2020_03_07_00_46_04_167" does not exist.
Gradle Test Executor 1 finished executing tests.
> Task :sdks:java:io:jdbc:integrationTest FAILED
org.apache.beam.sdk.io.jdbc.JdbcIOIT > classMethod FAILED
org.postgresql.util.PSQLException: ERROR: table "beamtest_it_2020_03_07_00_46_04_167" 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)
2 tests completed, 1 failed
Finished generating test XML results (0.033 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.044 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 8,5,main]) completed. Took 11 mins 24.32 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 46s
81 actionable tasks: 64 executed, 17 from cache
Publishing build scan...
https://gradle.com/s/zpcxvry7j5rs4
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PerformanceTests_JDBC #3250
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PerformanceTests_JDBC/3250/display/redirect>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PerformanceTests_JDBC #3249
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PerformanceTests_JDBC/3249/display/redirect?page=changes>
Changes:
[chadrik] [BEAM-9274] Support running yapf in a git pre-commit hook
[lcwik] [BEAM-9464] Fix WithKeys to respect parameterized types
[ankurgoenka] [BEAM-9465] Fire repeatedly in reshuffle
------------------------------------------
[...truncated 472.70 KB...]
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:52.719Z: Finished operation Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Create
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:52.740Z: Executing operation JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:52.765Z: Executing operation PAssert$2/GroupGlobally/GroupDummyAndContents/Create
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:52.770Z: Finished operation PAssert$2/GroupGlobally/GatherAllOutputs/GroupByKey/Create
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:52.790Z: Executing operation Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Create
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:52.795Z: Finished operation JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:52.819Z: Finished operation PAssert$2/GroupGlobally/GroupDummyAndContents/Create
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:52.862Z: Finished operation Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey/Create
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:53.283Z: Executing operation PAssert$3/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$3/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$3/GroupGlobally/GroupDummyAndContents/Reify+PAssert$3/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:53.358Z: Executing operation PAssert$0/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$0/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$0/GroupGlobally/GroupDummyAndContents/Reify+PAssert$0/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:53.394Z: Executing operation PAssert$1/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$1/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$1/GroupGlobally/GroupDummyAndContents/Reify+PAssert$1/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 6:37:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:37:53.423Z: Executing operation PAssert$2/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$2/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$2/GroupGlobally/GroupDummyAndContents/Reify+PAssert$2/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 6:37:59 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2020-03-07T06:37:58.460Z: Your project already contains 100 Dataflow-created metric descriptors and Stackdriver will not create new Dataflow custom metrics for this job. Each unique user-defined metric name (independent of the DoFn in which it is defined) produces a new metric descriptor. To 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
Mar 07, 2020 6:38:18 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:38:18.418Z: Autoscaling: Raised the number of workers to 5 based on the rate of progress in the currently running step(s).
Mar 07, 2020 6:38:37 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:38:37.020Z: Workers have started successfully.
Mar 07, 2020 6:38:37 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:38:37.050Z: Workers have started successfully.
Mar 07, 2020 6:38:53 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:38:51.917Z: Finished operation PAssert$1/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$1/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$1/GroupGlobally/GroupDummyAndContents/Reify+PAssert$1/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 6:38:53 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:38:52.085Z: Finished operation PAssert$0/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$0/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$0/GroupGlobally/GroupDummyAndContents/Reify+PAssert$0/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 6:38:55 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:38:54.276Z: Finished operation PAssert$2/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$2/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$2/GroupGlobally/GroupDummyAndContents/Reify+PAssert$2/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 6:38:55 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:38:55.008Z: Finished operation PAssert$3/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$3/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$3/GroupGlobally/GroupDummyAndContents/Reify+PAssert$3/GroupGlobally/GroupDummyAndContents/Write
Mar 07, 2020 6:39:06 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
SEVERE: 2020-03-07T06:39:05.185Z: java.lang.RuntimeException: org.apache.beam.sdk.util.UserCodeException: org.postgresql.util.PSQLException: The connection attempt failed.
at org.apache.beam.runners.dataflow.worker.IntrinsicMapTaskExecutorFactory$1.typedApply(IntrinsicMapTaskExecutorFactory.java:194)
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:353)
at org.apache.beam.runners.dataflow.worker.BatchDataflowWorker.getAndPerformWork(BatchDataflowWorker.java:306)
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)
Caused by: org.apache.beam.sdk.util.UserCodeException: org.postgresql.util.PSQLException: The connection attempt failed.
at org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:36)
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)
... 14 more
Caused by: org.postgresql.util.PSQLException: The connection attempt failed.
at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:257)
at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49)
at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:195)
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)
Caused by: java.net.SocketTimeoutException: connect timed out
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at org.postgresql.core.PGStream.<init>(PGStream.java:69)
at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:156)
at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49)
at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:195)
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:353)
at org.apache.beam.runners.dataflow.worker.BatchDataflowWorker.getAndPerformWork(BatchDataflowWorker.java:306)
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)
Mar 07, 2020 6:39:10 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
SEVERE: 2020-03-07T06:39:08.927Z: org.postgresql.util.PSQLException: ERROR: relation "beamtest_it_2020_03_07_06_31_45_852" does not exist
Position: 21
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.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:155)
at org.postgresql.jdbc.PgPreparedStatement.executeQuery(PgPreparedStatement.java:118)
at org.apache.beam.sdk.io.jdbc.JdbcIO$ReadFn.processElement(JdbcIO.java:892)
Mar 07, 2020 6:39:13 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
SEVERE: 2020-03-07T06:39:12.221Z: org.postgresql.util.PSQLException: ERROR: relation "beamtest_it_2020_03_07_06_31_45_852" does not exist
Position: 21
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.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:155)
at org.postgresql.jdbc.PgPreparedStatement.executeQuery(PgPreparedStatement.java:118)
at org.apache.beam.sdk.io.jdbc.JdbcIO$ReadFn.processElement(JdbcIO.java:892)
Mar 07, 2020 6:39:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
SEVERE: 2020-03-07T06:39:13.593Z: org.postgresql.util.PSQLException: ERROR: relation "beamtest_it_2020_03_07_06_31_45_852" does not exist
Position: 21
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.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:155)
at org.postgresql.jdbc.PgPreparedStatement.executeQuery(PgPreparedStatement.java:118)
at org.apache.beam.sdk.io.jdbc.JdbcIO$ReadFn.processElement(JdbcIO.java:892)
Mar 07, 2020 6:39:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:39:13.974Z: 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)
Mar 07, 2020 6:39:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
SEVERE: 2020-03-07T06:39:14.081Z: Workflow failed. Causes: S06: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) failed., The job failed because a work item has failed 4 times. Look in previous log entries for the cause of each one of the 4 failures. For more information, see https://cloud.google.com/dataflow/docs/guides/common-errors. The work item was attempted on these workers:
jdbcioit0testwritethenrea-03062237-8pla-harness-n66l
Root cause: Work item failed.,
jdbcioit0testwritethenrea-03062237-8pla-harness-9nb8
Root cause: Work item failed.,
jdbcioit0testwritethenrea-03062237-8pla-harness-85zt
Root cause: Work item failed.,
jdbcioit0testwritethenrea-03062237-8pla-harness-n66l
Root cause: Work item failed.
Mar 07, 2020 6:39:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:39:14.220Z: Cleaning up.
Mar 07, 2020 6:39:14 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:39:14.336Z: Stopping worker pool...
Mar 07, 2020 6:40:41 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:40:41.188Z: Autoscaling: Resized worker pool from 5 to 0.
Mar 07, 2020 6:40:41 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2020-03-07T06:40:41.227Z: Worker pool stopped.
Mar 07, 2020 6:41:51 AM org.apache.beam.runners.dataflow.DataflowPipelineJob logTerminalState
INFO: Job 2020-03-06_22_37_31-8440987085686113912 failed with status FAILED.
org.apache.beam.sdk.io.jdbc.JdbcIOIT > testWriteThenRead STANDARD_OUT
Load test results for test (ID): 337b2fdb-e7f8-4199-adee-41d228c71a47 and timestamp: 2020-03-07T06:41:51.693000000Z:
Metric: Value:
write_time 71.54
Load test results for test (ID): 337b2fdb-e7f8-4199-adee-41d228c71a47 and timestamp: 2020-03-07T06:41:51.693000000Z:
Metric: Value:
read_time 0.0
org.apache.beam.sdk.io.jdbc.JdbcIOIT STANDARD_ERROR
Mar 07, 2020 6:41:52 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Attempt #1 of 3 failed: ERROR: table "beamtest_it_2020_03_07_06_31_45_852" does not exist.
Mar 07, 2020 6:41:52 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Retrying in 2000 ms.
Mar 07, 2020 6:41:54 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Attempt #2 of 3 failed: ERROR: table "beamtest_it_2020_03_07_06_31_45_852" does not exist.
Mar 07, 2020 6:41:54 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Retrying in 4000 ms.
Mar 07, 2020 6:41:58 AM org.apache.beam.sdk.io.common.IOITHelper executeWithRetry
WARNING: Attempt #3 of 3 failed: ERROR: table "beamtest_it_2020_03_07_06_31_45_852" does not exist.
Gradle Test Executor 1 finished executing tests.
> Task :sdks:java:io:jdbc:integrationTest FAILED
org.apache.beam.sdk.io.jdbc.JdbcIOIT > classMethod FAILED
org.postgresql.util.PSQLException: ERROR: table "beamtest_it_2020_03_07_06_31_45_852" 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)
2 tests completed, 1 failed
Finished generating test XML results (0.043 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.047 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 ':',5,main]) completed. Took 10 mins 16.527 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 7s
81 actionable tasks: 62 executed, 19 from cache
Publishing build scan...
https://gradle.com/s/gthpw6rt6pbmg
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org