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 2019/03/13 18:35:28 UTC
Build failed in Jenkins: beam_PerformanceTests_ManyFiles_TextIOIT
#299
See <https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/299/display/redirect?page=changes>
Changes:
[pabloem] Automatically retrieving JDK 11 containers
[gleb] Fix usage of non-vendored guava in BigTableIO
[pablo] Update Py3 postcommit tests. (#8014)
------------------------------------------
[...truncated 288.70 KB...]
INFO: 2019-03-13T18:16:23.494Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map into PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:23.549Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) into PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:23.621Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:23.682Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial into PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:23.736Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write into PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:23.797Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues into PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:23.846Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify into PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:23.912Z: Fusing consumer PAssert$0/CreateActual/FilterActuals/Window.Assign into Calculate hashcode/ProduceDefault
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.035Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map into Calculate hashcode/ProduceDefault
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.080Z: Fusing consumer Read all files/FileIO.MatchAll/Match filepatterns into Collect write end time
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.159Z: Fusing consumer Calculate hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow) into Calculate hashcode/Values/Values/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.213Z: Fusing consumer PAssert$0/CreateActual/GatherPanes/WithKeys/AddKeys/Map into PAssert$0/CreateActual/GatherPanes/Reify.Window/ParDo(Anonymous)
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.258Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.314Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.381Z: Fusing consumer Read all files/FileIO.ReadMatches/ParDo(ToReadableFile) into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Values/Values/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.458Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Write into Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Reify
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.502Z: Fusing consumer Calculate hashcode/WithKeys/AddKeys/Map into Collect read end time
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.568Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign into Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair with random key
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.682Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Reify into Calculate hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.751Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Values/Values/Map into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.824Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.896Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.948Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial into Calculate hashcode/WithKeys/AddKeys/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:24.993Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map into Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.067Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Write into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Reify
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.120Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.199Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair with random key into Write content to files/WriteFiles/FinalizeTempFileBundles/Finalize
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.278Z: Fusing consumer Calculate hashcode/ProduceDefault into Calculate hashcode/CreateVoid/Read(CreateSource)
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.332Z: Fusing consumer Calculate hashcode/Values/Values/Map into Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.391Z: Fusing consumer Write content to files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map into Write content to files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.457Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.540Z: Fusing consumer Collect read end time into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Read ranges
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.584Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Finalize into Write content to files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.642Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Pair with random key
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.718Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Pair with random key into Read all files/FileIO.MatchAll/Match filepatterns
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.778Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Reify into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/Window.Into()/Window.Assign
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.845Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow into Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.905Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/GroupByWindow into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Read
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:25.948Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/Window.Into()/Window.Assign into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Pair with random key
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.034Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write into Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.088Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Split into ranges into Read all files/FileIO.ReadMatches/ParDo(ToReadableFile)
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.156Z: Fusing consumer Collect write end time into Values/Values/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.224Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract into Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.280Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues into Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Read
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.352Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Pair with random key into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Split into ranges
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.425Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Read ranges into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Values/Values/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.504Z: Fusing consumer Values/Values/Map into Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.554Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify into Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:26.617Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Values/Values/Map into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/ExpandIterable
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.148Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable into Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.269Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/ExpandIterable into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/GroupByWindow
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.325Z: Fusing consumer Write content to files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous) into Write content to files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.379Z: Fusing consumer Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/Write into Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/Reify
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.446Z: Fusing consumer Collect write start time into Produce text lines
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.500Z: Fusing consumer Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/ApplyShardingKey into Write content to files/WriteFiles/RewindowIntoGlobal/Window.Assign
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.554Z: Fusing consumer Write content to files/WriteFiles/GatherTempFileResults/View.AsList/ParDo(ToIsmRecordForGlobalWindow) into Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/WriteShardsIntoTempFiles
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.616Z: Fusing consumer Produce text lines into Generate sequence/Read(BoundedCountingSource)
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.682Z: Fusing consumer Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/Reify into Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/ApplyShardingKey
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.735Z: Fusing consumer Write content to files/WriteFiles/RewindowIntoGlobal/Window.Assign into Collect write start time
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.815Z: Fusing consumer Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/WriteShardsIntoTempFiles into Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/GroupByWindow
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.909Z: Fusing consumer Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/GroupByWindow into Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/Read
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:27.964Z: Fusing consumer PAssert$0/VerifyAssertions/ParDo(DefaultConclude) into PAssert$0/RunChecks
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:28.019Z: Fusing consumer PAssert$0/WindowToken/Window.Assign into PAssert$0/Create.Values/Read(CreateSource)
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:28.083Z: Fusing consumer PAssert$0/RunChecks into PAssert$0/WindowToken/Window.Assign
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:28.912Z: Executing operation Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:28.972Z: Executing operation Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:29.026Z: Executing operation Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:29.062Z: Starting 1 workers in us-central1-b...
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:29.098Z: Executing operation Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:29.155Z: Executing operation PAssert$0/CreateActual/GatherPanes/GroupByKey/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:29.222Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:29.273Z: Executing operation Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:29.337Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:29.414Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:29.473Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Mar 13, 2019 6:16:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:30.333Z: Executing operation Generate sequence/Read(BoundedCountingSource)+Produce text lines+Collect write start time+Write content to files/WriteFiles/RewindowIntoGlobal/Window.Assign+Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/ApplyShardingKey+Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/Reify+Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/Write
Mar 13, 2019 6:16:43 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:16:42.666Z: Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
Mar 13, 2019 6:17:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:17:15.601Z: Workers have started successfully.
Mar 13, 2019 6:17:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:17:17.034Z: Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s).
Mar 13, 2019 6:17:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:17:17.091Z: Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
Mar 13, 2019 6:17:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:17:47.143Z: Workers have started successfully.
Mar 13, 2019 6:17:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:17:53.105Z: Executing operation Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/Close
Mar 13, 2019 6:17:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:17:53.316Z: Executing operation Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/Read+Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/GroupIntoShards/GroupByWindow+Write content to files/WriteFiles/WriteShardedBundlesToTempFiles/WriteShardsIntoTempFiles+Write content to files/WriteFiles/GatherTempFileResults/View.AsList/ParDo(ToIsmRecordForGlobalWindow)
Mar 13, 2019 6:30:22 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:29:31.087Z: Executing operation Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable+Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map+Values/Values/Map+Collect write end time+Read all files/FileIO.MatchAll/Match filepatterns+Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Pair with random key+Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign+Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify+Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
Mar 13, 2019 6:30:53 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:30:52.784Z: Executing operation Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Mar 13, 2019 6:30:53 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:30:53.001Z: Executing operation Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable+Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Values/Values/Map+Read all files/FileIO.ReadMatches/ParDo(ToReadableFile)+Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Split into ranges+Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Pair with random key+Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/Window.Into()/Window.Assign+Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Reify+Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Write
Mar 13, 2019 6:30:59 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:30:58.794Z: Executing operation Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Close
Mar 13, 2019 6:30:59 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:30:58.925Z: Executing operation Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Read+Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/GroupByWindow+Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Reshuffle/ExpandIterable+Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Reshuffle/Values/Values/Map+Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Read ranges+Collect read end time+Calculate hashcode/WithKeys/AddKeys/Map+Calculate hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial+Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Reify+Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Write
Mar 13, 2019 6:33:11 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:08.976Z: Executing operation Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Close
Mar 13, 2019 6:33:11 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:09.132Z: Executing operation Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Read+Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues+Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract+Calculate hashcode/Values/Values/Map+PAssert$0/CreateActual/FilterActuals/Window.Assign+PAssert$0/CreateActual/GatherPanes/Reify.Window/ParDo(Anonymous)+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+PAssert$0/CreateActual/GatherPanes/WithKeys/AddKeys/Map+PAssert$0/CreateActual/GatherPanes/Window.Into()/Window.Assign+PAssert$0/CreateActual/GatherPanes/GroupByKey/Reify+PAssert$0/CreateActual/GatherPanes/GroupByKey/Write+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write+Calculate hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
Mar 13, 2019 6:33:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:14.324Z: Executing operation Calculate hashcode/View.AsIterable/CreateDataflowView
Mar 13, 2019 6:33:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:14.602Z: Executing operation Calculate hashcode/CreateVoid/Read(CreateSource)+Calculate hashcode/ProduceDefault+PAssert$0/CreateActual/FilterActuals/Window.Assign+PAssert$0/CreateActual/GatherPanes/Reify.Window/ParDo(Anonymous)+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+PAssert$0/CreateActual/GatherPanes/WithKeys/AddKeys/Map+PAssert$0/CreateActual/GatherPanes/Window.Into()/Window.Assign+PAssert$0/CreateActual/GatherPanes/GroupByKey/Reify+PAssert$0/CreateActual/GatherPanes/GroupByKey/Write+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
Mar 13, 2019 6:33:20 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:17.195Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Mar 13, 2019 6:33:20 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:17.243Z: Executing operation PAssert$0/CreateActual/GatherPanes/GroupByKey/Close
Mar 13, 2019 6:33:20 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:17.317Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Mar 13, 2019 6:33:20 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:17.380Z: Executing operation PAssert$0/CreateActual/GatherPanes/GroupByKey/Read+PAssert$0/CreateActual/GatherPanes/GroupByKey/GroupByWindow+PAssert$0/CreateActual/GatherPanes/Values/Values/Map+PAssert$0/CreateActual/ExtractPane/Map+PAssert$0/CreateActual/Flatten.Iterables/FlattenIterables/FlatMap+PAssert$0/CreateActual/RewindowActuals/Window.Assign+PAssert$0/CreateActual/ParDo(Anonymous)+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
Mar 13, 2019 6:33:23 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:22.281Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
Mar 13, 2019 6:33:23 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:22.723Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
Mar 13, 2019 6:33:28 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:27.441Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Mar 13, 2019 6:33:28 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:27.557Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Mar 13, 2019 6:33:31 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:29.539Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
Mar 13, 2019 6:33:31 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:29.671Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
Mar 13, 2019 6:33:40 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:38.305Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/CreateDataflowView
Mar 13, 2019 6:33:40 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:38.544Z: Executing operation Delete test files
Mar 13, 2019 6:33:41 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:40.443Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/CreateDataflowView
Mar 13, 2019 6:33:41 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2019-03-13T18:33:40.757Z: Executing operation PAssert$0/Create.Values/Read(CreateSource)+PAssert$0/WindowToken/Window.Assign+PAssert$0/RunChecks+PAssert$0/VerifyAssertions/ParDo(DefaultConclude)
STDERR:
2019-03-13 18:35:28,006 a15c2773 MainThread beam_integration_benchmark(1/1) ERROR Error during benchmark beam_integration_benchmark
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",> line 734, in RunBenchmark
DoRunPhase(spec, collector, detailed_timer)
File "<https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",> line 589, in DoRunPhase
samples = spec.BenchmarkRun(spec)
File "<https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/linux_benchmarks/beam_integration_benchmark.py",> line 160, in Run
job_type=job_type)
File "<https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/providers/gcp/gcp_dpb_dataflow.py",> line 90, in SubmitJob
assert retcode == 0, "Integration Test Failed."
AssertionError: Integration Test Failed.
2019-03-13 18:35:28,008 a15c2773 MainThread beam_integration_benchmark(1/1) INFO Cleaning up benchmark beam_integration_benchmark
2019-03-13 18:35:28,013 a15c2773 MainThread beam_integration_benchmark(1/1) ERROR Exception running benchmark
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",> line 874, in RunBenchmarkTask
RunBenchmark(spec, collector)
File "<https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",> line 734, in RunBenchmark
DoRunPhase(spec, collector, detailed_timer)
File "<https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",> line 589, in DoRunPhase
samples = spec.BenchmarkRun(spec)
File "<https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/linux_benchmarks/beam_integration_benchmark.py",> line 160, in Run
job_type=job_type)
File "<https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/providers/gcp/gcp_dpb_dataflow.py",> line 90, in SubmitJob
assert retcode == 0, "Integration Test Failed."
AssertionError: Integration Test Failed.
2019-03-13 18:35:28,013 a15c2773 MainThread beam_integration_benchmark(1/1) ERROR Benchmark 1/1 beam_integration_benchmark (UID: beam_integration_benchmark0) failed. Execution will continue.
2019-03-13 18:35:28,014 a15c2773 MainThread beam_integration_benchmark(1/1) INFO Benchmark run statuses:
---------------------------------------------------------------------------------
Name UID Status Failed Substatus
---------------------------------------------------------------------------------
beam_integration_benchmark beam_integration_benchmark0 FAILED
---------------------------------------------------------------------------------
Success rate: 0.00% (0/1)
2019-03-13 18:35:28,014 a15c2773 MainThread beam_integration_benchmark(1/1) INFO Complete logs can be found at: <https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/runs/a15c2773/pkb.log>
2019-03-13 18:35:28,014 a15c2773 MainThread beam_integration_benchmark(1/1) INFO Completion statuses can be found at: <https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/ws/runs/a15c2773/completion_statuses.json>
Build step 'Execute shell' 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_ManyFiles_TextIOIT #300
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PerformanceTests_ManyFiles_TextIOIT/300/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org