See
<https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/370/display/redirect>
------------------------------------------
[...truncated 18.91 MB...]
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.435Z: Fusing consumer
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Reify into
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/Window.Into()/Window.Assign
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.453Z: Fusing consumer
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/GroupByWindow
into BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Read
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.476Z: Fusing consumer
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Write into
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Reify
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.500Z: Fusing consumer
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
into
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.519Z: Fusing consumer
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
into
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.541Z: Fusing consumer
BigQueryIO.Write/BatchLoads/ReifyRenameInput/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
into
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/ParMultiDo(WriteTables)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.559Z: Fusing consumer
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/ParMultiDo(WriteTables)
into BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/ExpandIterable
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.577Z: Fusing consumer
BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Reify into
BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/Window.Into()/Window.Assign
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.597Z: Fusing consumer
BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/GroupByWindow
into BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Read
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.611Z: Fusing consumer
BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Write into
BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Reify
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.636Z: Unzipping flatten s46 for input
s43.writtenFiles
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.661Z: Fusing unzipped copy of
BigQueryIO.Write/BatchLoads/ReifyResults/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow),
through flatten BigQueryIO.Write/BatchLoads/FlattenFiles, into producer
BigQueryIO.Write/BatchLoads/WriteBundlesToFiles
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.687Z: Fusing consumer
BigQueryIO.Write/BatchLoads/ReifyResults/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
into BigQueryIO.Write/BatchLoads/WriteGroupedRecords
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.708Z: Fusing consumer
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify
into
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey+BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Partial
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.722Z: Fusing consumer
BigQueryIO.Write/BatchLoads/GroupByDestination/Reify into
BigQueryIO.Write/BatchLoads/WriteBundlesToFiles
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.751Z: Fusing consumer
BigQueryIO.Write/BatchLoads/WriteGroupedRecords into
BigQueryIO.Write/BatchLoads/GroupByDestination/GroupByWindow
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.769Z: Fusing consumer
BigQueryTornadoes.CountTornadoes/Count.PerElement/Init/Map into
BigQueryTornadoes.CountTornadoes/ParDo(ExtractTornadoes)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.793Z: Fusing consumer
BigQueryIO.Write/BatchLoads/GroupByDestination/Write into
BigQueryIO.Write/BatchLoads/GroupByDestination/Reify
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.816Z: Fusing consumer
BigQueryIO.Write/BatchLoads/WriteBundlesToFiles into
BigQueryIO.Write/BatchLoads/rewindowIntoGlobal/Window.Assign
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.839Z: Fusing consumer
BigQueryIO.Write/BatchLoads/rewindowIntoGlobal/Window.Assign into
BigQueryIO.Write/PrepareWrite/ParDo(Anonymous)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.865Z: Fusing consumer
BigQueryIO.Write/PrepareWrite/ParDo(Anonymous) into
BigQueryTornadoes.CountTornadoes/ParDo(FormatCounts)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.889Z: Fusing consumer
BigQueryTornadoes.CountTornadoes/ParDo(ExtractTornadoes) into
BigQueryIO.TypedRead/PassThroughThenCleanup/ParMultiDo(Identity)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.912Z: Fusing consumer
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues
into
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.938Z: Fusing consumer
BigQueryIO.TypedRead/PassThroughThenCleanup/ParMultiDo(Identity) into
BigQueryIO.TypedRead/Read(BigQueryTableSource)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.957Z: Fusing consumer
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey/Write
into
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.973Z: Fusing consumer
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract
into
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:22.996Z: Fusing consumer
BigQueryIO.Write/BatchLoads/GroupByDestination/GroupByWindow into
BigQueryIO.Write/BatchLoads/GroupByDestination/Read
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.017Z: Fusing consumer
BigQueryIO.TypedRead/PassThroughThenCleanup/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
into BigQueryIO.TypedRead/PassThroughThenCleanup/ParMultiDo(Identity)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.040Z: Fusing consumer
BigQueryTornadoes.CountTornadoes/ParDo(FormatCounts) into
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.054Z: Fusing consumer
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey+BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Partial
into BigQueryTornadoes.CountTornadoes/Count.PerElement/Init/Map
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.078Z: Fusing consumer
BigQueryIO.TypedRead/PassThroughThenCleanup/Cleanup into
BigQueryIO.TypedRead/PassThroughThenCleanup/Create(CleanupOperation)/Read(CreateSource)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.103Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify
into
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.123Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
into
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.149Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues
into
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.174Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
into
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.197Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
into
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.220Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
into
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.244Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
into
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.266Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
into BigQueryIO.TypedRead/TriggerIdCreation/Read(CreateSource)
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.291Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
into
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.315Z: Fusing consumer
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
into
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.598Z: Executing operation
BigQueryIO.Write/BatchLoads/CreateEmptyFailedInserts/Read(CreateSource)+DropInputs
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.624Z: Executing operation
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.642Z: Executing operation
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.655Z: Starting 1 workers in us-central1-b...
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.665Z: Executing operation
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.690Z: Executing operation
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.713Z: Executing operation
BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.736Z: Executing operation
BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.758Z: Executing operation
BigQueryIO.Write/BatchLoads/GroupByDestination/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.784Z: Executing operation
BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.809Z: Executing operation
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.833Z: Executing operation
BigQueryIO.Write/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.854Z: Executing operation
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:23.870Z: Executing operation
BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/GroupByKey/Create
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:24.184Z: Executing operation
BigQueryIO.Write/BatchLoads/JobIdCreationRoot/Read(CreateSource)+BigQueryIO.Write/BatchLoads/CreateJobId+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:24.208Z: Executing operation
BigQueryIO.TypedRead/Read(BigQueryTableSource)+BigQueryIO.TypedRead/PassThroughThenCleanup/ParMultiDo(Identity)+BigQueryTornadoes.CountTornadoes/ParDo(ExtractTornadoes)+BigQueryTornadoes.CountTornadoes/Count.PerElement/Init/Map+BigQueryIO.TypedRead/PassThroughThenCleanup/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey+BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Partial+BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey/Reify+BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey/Write
May 12, 2018 12:42:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:24.233Z: Executing operation
BigQueryIO.TypedRead/TriggerIdCreation/Read(CreateSource)+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
May 12, 2018 12:42:31 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:42:31.184Z: Autoscaling: Raised the number of workers
to 0 based on the rate of progress in the currently running step(s).
May 12, 2018 12:43:25 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:43:24.737Z: Autoscaling: Raised the number of workers
to 1 based on the rate of progress in the currently running step(s).
May 12, 2018 12:43:53 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:43:52.786Z: Workers have started successfully.
May 12, 2018 12:44:20 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:19.646Z: Executing operation
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
May 12, 2018 12:44:20 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:19.717Z: Executing operation
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
May 12, 2018 12:44:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:25.712Z: Executing operation
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
May 12, 2018 12:44:28 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:25.770Z: Executing operation
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
May 12, 2018 12:44:36 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:34.630Z: Executing operation
BigQueryIO.TypedRead/ViewId/Combine.GloballyAsSingletonView/CreateDataflowView
May 12, 2018 12:44:36 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:34.979Z: Executing operation
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
May 12, 2018 12:44:36 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:35.044Z: Executing operation
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
May 12, 2018 12:44:42 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:39.697Z: Executing operation
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
May 12, 2018 12:44:42 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:39.768Z: Executing operation
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
May 12, 2018 12:44:45 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:44.004Z: Executing operation
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close
May 12, 2018 12:44:45 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:44.042Z: Executing operation
BigQueryIO.TypedRead/PassThroughThenCleanup/View.AsIterable/CreateDataflowView
May 12, 2018 12:44:45 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:44.191Z: Executing operation
BigQueryIO.TypedRead/PassThroughThenCleanup/Create(CleanupOperation)/Read(CreateSource)+BigQueryIO.TypedRead/PassThroughThenCleanup/Cleanup
May 12, 2018 12:44:52 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:51.409Z: Executing operation
BigQueryIO.Write/BatchLoads/View.AsSingleton/Combine.GloballyAsSingletonView/CreateDataflowView
May 12, 2018 12:44:52 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:51.535Z: Executing operation
BigQueryIO.Write/BatchLoads/Create.Values/Read(CreateSource)+BigQueryIO.Write/BatchLoads/GetTempFilePrefix+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
May 12, 2018 12:44:52 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:52.067Z: Executing operation
BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
May 12, 2018 12:44:54 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:52.120Z: Executing operation
BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
May 12, 2018 12:44:56 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:54.630Z: Executing operation
BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
May 12, 2018 12:44:56 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:44:54.687Z: Executing operation
BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
May 12, 2018 12:45:02 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:00.243Z: Executing operation
BigQueryIO.Write/BatchLoads/TempFilePrefixView/Combine.GloballyAsSingletonView/CreateDataflowView
May 12, 2018 12:45:02 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:00.368Z: Executing operation
BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+BigQueryTornadoes.CountTornadoes/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+BigQueryTornadoes.CountTornadoes/ParDo(FormatCounts)+BigQueryIO.Write/PrepareWrite/ParDo(Anonymous)+BigQueryIO.Write/BatchLoads/rewindowIntoGlobal/Window.Assign+BigQueryIO.Write/BatchLoads/WriteBundlesToFiles+BigQueryIO.Write/BatchLoads/ReifyResults/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+BigQueryIO.Write/BatchLoads/GroupByDestination/Reify+BigQueryIO.Write/BatchLoads/GroupByDestination/Write
May 12, 2018 12:45:08 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:08.239Z: Executing operation
BigQueryIO.Write/BatchLoads/GroupByDestination/Close
May 12, 2018 12:45:08 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:08.297Z: Executing operation
BigQueryIO.Write/BatchLoads/GroupByDestination/Read+BigQueryIO.Write/BatchLoads/GroupByDestination/GroupByWindow+BigQueryIO.Write/BatchLoads/WriteGroupedRecords+BigQueryIO.Write/BatchLoads/ReifyResults/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
May 12, 2018 12:45:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:10.885Z: Executing operation s46-u136
May 12, 2018 12:45:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:11.078Z: Executing operation
BigQueryIO.Write/BatchLoads/ReifyResults/View.AsIterable/CreateDataflowView
May 12, 2018 12:45:11 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:11.261Z: Executing operation
BigQueryIO.Write/BatchLoads/ReifyResults/Create.Values/Read(CreateSource)+BigQueryIO.Write/BatchLoads/ReifyResults/ParDo(Anonymous)+BigQueryIO.Write/BatchLoads/WritePartitionUntriggered+BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/Window.Into()/Window.Assign+BigQueryIO.Write/BatchLoads/SinglePartitionsReshuffle/Window.Into()/Window.Assign+BigQueryIO.Write/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Reify+BigQueryIO.Write/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Write+BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Reify+BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Write
May 12, 2018 12:45:14 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:13.153Z: Executing operation
BigQueryIO.Write/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Close
May 12, 2018 12:45:14 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:13.198Z: Executing operation
BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Close
May 12, 2018 12:45:14 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:13.249Z: Executing operation
BigQueryIO.Write/BatchLoads/SinglePartitionsReshuffle/GroupByKey/Read+BigQueryIO.Write/BatchLoads/SinglePartitionsReshuffle/GroupByKey/GroupByWindow+BigQueryIO.Write/BatchLoads/SinglePartitionsReshuffle/ExpandIterable+BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/ParMultiDo(WriteTables)+BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/WithKeys/AddKeys/Map+BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/Window.Into()/Window.Assign+BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/GroupByKey/Reify+BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/GroupByKey/Write
May 12, 2018 12:45:14 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:13.284Z: Executing operation
BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/Read+BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/GroupByKey/GroupByWindow+BigQueryIO.Write/BatchLoads/MultiPartitionsReshuffle/ExpandIterable+BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/ParMultiDo(WriteTables)+BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/WithKeys/AddKeys/Map+BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/Window.Into()/Window.Assign+BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Reify+BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Write+BigQueryIO.Write/BatchLoads/ReifyRenameInput/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
May 12, 2018 12:45:17 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:16.519Z: Executing operation
BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/GroupByKey/Close
May 12, 2018 12:45:17 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:16.590Z: Executing operation
BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/GroupByKey/Read+BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/GroupByKey/GroupByWindow+BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/Values/Values/Map+BigQueryIO.Write/BatchLoads/SinglePartitionWriteTables/ParDo(GarbageCollectTemporaryFiles)
May 12, 2018 12:45:20 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:20.442Z: Executing operation
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Close
May 12, 2018 12:45:20 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:20.472Z: Executing operation
BigQueryIO.Write/BatchLoads/ReifyRenameInput/View.AsIterable/CreateDataflowView
May 12, 2018 12:45:20 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:20.506Z: Executing operation
BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/Read+BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/GroupByKey/GroupByWindow+BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/Values/Values/Map+BigQueryIO.Write/BatchLoads/MultiPartitionsWriteTables/ParDo(GarbageCollectTemporaryFiles)
May 12, 2018 12:45:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:20.612Z: Executing operation
BigQueryIO.Write/BatchLoads/ReifyRenameInput/Create.Values/Read(CreateSource)+BigQueryIO.Write/BatchLoads/ReifyRenameInput/ParDo(Anonymous)+BigQueryIO.Write/BatchLoads/WriteRenameUntriggered
May 12, 2018 12:45:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:21.219Z: Cleaning up.
May 12, 2018 12:45:23 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:45:21.570Z: Stopping worker pool...
May 12, 2018 12:46:55 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:46:55.517Z: Autoscaling: Resized worker pool from 1 to
0.
May 12, 2018 12:46:55 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:46:55.553Z: Autoscaling: Would further reduce the
number of workers but reached the minimum number allowed for the job.
May 12, 2018 12:46:55 AM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-05-12T00:46:55.586Z: Worker pool stopped.
May 12, 2018 12:47:05 AM
org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish
INFO: Job 2018-05-11_17_42_14-17288870654433224079 finished with status
DONE.
May 12, 2018 12:47:05 AM
org.apache.beam.runners.dataflow.TestDataflowRunner checkForPAssertSuccess
INFO: Success result for Dataflow job
2018-05-11_17_42_14-17288870654433224079. Found 0 success, 0 failures out of 0
expected assertions.
May 12, 2018 12:47:05 AM org.apache.beam.sdk.io.gcp.testing.BigqueryMatcher
matchesSafely
INFO: Verifying Bigquery data
May 12, 2018 12:47:06 AM
org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish
INFO: Job 2018-05-11_17_42_14-17288870654433224079 finished with status
DONE.
Gradle Test Executor 131 finished executing tests.
> Task :beam-runners-google-cloud-dataflow-java:examplesJavaIntegrationTest
Finished generating test XML results (0.002 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/ws/src/runners/google-cloud-dataflow-java/build/test-results/examplesJavaIntegrationTest>
Generating HTML test report...
Finished generating test html results (0.003 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/ws/src/runners/google-cloud-dataflow-java/build/reports/tests/examplesJavaIntegrationTest>
Packing task
':beam-runners-google-cloud-dataflow-java:examplesJavaIntegrationTest'
:beam-runners-google-cloud-dataflow-java:examplesJavaIntegrationTest
(Thread[Task worker for ':' Thread 4,5,main]) completed. Took 5 mins 4.783 secs.
:beam-runners-google-cloud-dataflow-java:postCommit (Thread[Task worker for ':'
Thread 4,5,main]) started.
> Task :beam-runners-google-cloud-dataflow-java:postCommit
Skipping task ':beam-runners-google-cloud-dataflow-java:postCommit' as it has
no actions.
:beam-runners-google-cloud-dataflow-java:postCommit (Thread[Task worker for ':'
Thread 4,5,main]) completed. Took 0.0 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11:compileTestJava'.
> Compilation failed with exit code 1; see the compiler error output for
> details.
* 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 5.0.
See
https://docs.gradle.org/4.7/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 46m 9s
530 actionable tasks: 525 executed, 5 from cache
Publishing build scan...
https://gradle.com/s/ysc5da57gmpti
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Recording test results
Not sending mail to unregistered user [email protected]
