beam-builds mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: beam_PerformanceTests_Compressed_TextIOIT #1431
Date Mon, 07 Jan 2019 12:58:35 GMT
See <https://builds.apache.org/job/beam_PerformanceTests_Compressed_TextIOIT/1431/display/redirect?page=changes>

Changes:

[katarzyna.kucharczyk] [BEAM-5985] Create jenkins jobs to run the load tests for Java SDK

[katarzyna.kucharczyk] [BEAM-5985] Introduced Small Load test suite.

[katarzyna.kucharczyk] [BEAM-5985] Extracted common part for Nexmark and LoadTests in Jenkins

------------------------------------------
[...truncated 278.47 KB...]
    INFO: 2019-01-07T12:39:07.678Z: 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)
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:07.707Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:07.735Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:07.759Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:07.793Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:07.832Z: Fusing consumer PAssert$0/CreateActual/FilterActuals/Window.Assign
into Calculate hashcode/ProduceDefault
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:07.866Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
into Calculate hashcode/ProduceDefault
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:07.901Z: Fusing consumer Read all files/FileIO.MatchAll/Match filepatterns
into Values/Values/Map
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:07.939Z: Fusing consumer Calculate hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
into Calculate hashcode/Values/Values/Map
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:07.974Z: Fusing consumer PAssert$0/CreateActual/GatherPanes/WithKeys/AddKeys/Map
into PAssert$0/CreateActual/GatherPanes/Reify.Window/ParDo(Anonymous)
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.009Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.044Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.074Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Values/Values/Map
into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.105Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Write
into Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Reify
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.129Z: Fusing consumer Calculate hashcode/WithKeys/AddKeys/Map
into Read all files/TextIO.ReadFiles/Read all via FileBasedSource/Read ranges
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.162Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.208Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Reify
into Calculate hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.243Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial into Calculate hashcode/WithKeys/AddKeys/Map
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.280Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map
into Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.327Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.372Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.419Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Finalize
into Write content to files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.454Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.491Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.526Z: Fusing consumer Calculate hashcode/ProduceDefault into
Calculate hashcode/CreateVoid/Read(CreateSource)
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.560Z: Fusing consumer Calculate hashcode/Values/Values/Map into
Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.598Z: 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)
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.632Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.658Z: 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)
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.694Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.740Z: Fusing consumer Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Pair
with random key into Read all files/FileIO.MatchAll/Match filepatterns
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.788Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.833Z: Fusing consumer Values/Values/Map into Write content to
files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.870Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract
into Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.915Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues
into Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Read
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:08.959Z: Fusing consumer Read all files/TextIO.ReadFiles/Read all
via FileBasedSource/Split into ranges into Read all files/FileIO.ReadMatches/ParDo(ToReadableFile)
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.004Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.044Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.090Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.137Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.185Z: Fusing consumer Read all files/FileIO.ReadMatches/ParDo(ToReadableFile)
into Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Values/Values/Map
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.232Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.267Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
into Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.313Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.361Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.408Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.457Z: 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
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.502Z: Fusing consumer Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair
with random key into Write content to files/WriteFiles/FinalizeTempFileBundles/Finalize
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.548Z: Unzipping flatten s8 for input s4.writtenRecords
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.588Z: Fusing unzipped copy of Write content to files/WriteFiles/GatherTempFileResults/View.AsList/ParDo(ToIsmRecordForGlobalWindow),
through flatten Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/Flatten.PCollections,
into producer Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.628Z: Fusing consumer Write content to files/WriteFiles/GatherTempFileResults/View.AsList/ParDo(ToIsmRecordForGlobalWindow)
into Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.674Z: Fusing consumer Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Reify
into Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.722Z: Fusing consumer Produce text lines into Generate sequence/Read(BoundedCountingSource)
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.767Z: Fusing consumer Write content to files/WriteFiles/RewindowIntoGlobal/Window.Assign
into Produce text lines
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.811Z: Fusing consumer Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/GroupByWindow
into Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Read
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.848Z: Fusing consumer Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum
into Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.894Z: Fusing consumer Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten
into Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/GroupByWindow
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.940Z: Fusing consumer Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Write
into Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Reify
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:09.985Z: Fusing consumer Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles
into Write content to files/WriteFiles/RewindowIntoGlobal/Window.Assign
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.032Z: Fusing consumer PAssert$0/WindowToken/Window.Assign into
PAssert$0/Create.Values/Read(CreateSource)
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.071Z: Fusing consumer PAssert$0/VerifyAssertions/ParDo(DefaultConclude)
into PAssert$0/RunChecks
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.112Z: Fusing consumer PAssert$0/RunChecks into PAssert$0/WindowToken/Window.Assign
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.637Z: Executing operation Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.681Z: Executing operation Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.725Z: Starting 1 workers in us-central1-b...
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.725Z: Executing operation Read all files/TextIO.ReadFiles/Read
all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.763Z: Executing operation Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.798Z: Executing operation PAssert$0/CreateActual/GatherPanes/GroupByKey/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.833Z: Executing operation Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.872Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.905Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.941Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:10.976Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
    Jan 07, 2019 12:39:18 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:11.476Z: Executing operation Generate sequence/Read(BoundedCountingSource)+Produce
text lines+Write content to files/WriteFiles/RewindowIntoGlobal/Window.Assign+Write content
to files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles+Write content to
files/WriteFiles/GatherTempFileResults/View.AsList/ParDo(ToIsmRecordForGlobalWindow)+Write
content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Reify+Write content
to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Write
    Jan 07, 2019 12:39:23 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:21.542Z: Autoscaling: Raised the number of workers to 0 based on
the rate of progress in the currently running step(s).
    Jan 07, 2019 12:39:45 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:45.169Z: Autoscaling: Raised the number of workers to 1 based on
the rate of progress in the currently running step(s).
    Jan 07, 2019 12:39:45 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:45.202Z: Autoscaling: Would further reduce the number of workers
but reached the minimum number allowed for the job.
    Jan 07, 2019 12:39:47 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:46.728Z: Workers have started successfully.
    Jan 07, 2019 12:39:47 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:39:46.776Z: Workers have started successfully.
    Jan 07, 2019 12:40:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:16.739Z: Executing operation Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Close
    Jan 07, 2019 12:40:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:17.003Z: Executing operation Write content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Read+Write
content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/GroupByWindow+Write
content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten+Write content
to files/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum+Write content to files/WriteFiles/GatherTempFileResults/View.AsList/ParDo(ToIsmRecordForGlobalWindow)
    Jan 07, 2019 12:40:20 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:18.972Z: Executing operation s8-u145
    Jan 07, 2019 12:40:20 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:19.238Z: Executing operation Write content to files/WriteFiles/GatherTempFileResults/View.AsList/CreateDataflowView
    Jan 07, 2019 12:40:20 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:19.483Z: Executing operation Write content to files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)+Write
content to files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)+Write
content to files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map+Write
content to files/WriteFiles/FinalizeTempFileBundles/Finalize+Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair
with random key+Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign+Write
content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify+Write
content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
    Jan 07, 2019 12:40:24 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:23.093Z: Executing operation Write content to files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
    Jan 07, 2019 12:40:24 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:23.240Z: 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+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
    Jan 07, 2019 12:40:29 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:29.134Z: Executing operation Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
    Jan 07, 2019 12:40:29 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:29.380Z: 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
    Jan 07, 2019 12:40:35 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:34.038Z: Executing operation Read all files/TextIO.ReadFiles/Read
all via FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Close
    Jan 07, 2019 12:40:35 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:34.144Z: 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+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
    Jan 07, 2019 12:40:43 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:42.927Z: Executing operation Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Close
    Jan 07, 2019 12:40:43 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:43.051Z: 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)
    Jan 07, 2019 12:40:50 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:49.843Z: Executing operation Calculate hashcode/View.AsIterable/CreateDataflowView
    Jan 07, 2019 12:40:50 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:50.081Z: 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
    Jan 07, 2019 12:40:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:52.850Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
    Jan 07, 2019 12:40:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:52.891Z: Executing operation PAssert$0/CreateActual/GatherPanes/GroupByKey/Close
    Jan 07, 2019 12:40:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:52.951Z: 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
    Jan 07, 2019 12:40:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:53.006Z: 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
    Jan 07, 2019 12:41:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:59.499Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
    Jan 07, 2019 12:41:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:40:59.586Z: 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
    Jan 07, 2019 12:41:04 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:41:03.776Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
    Jan 07, 2019 12:41:04 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:41:03.929Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
    Jan 07, 2019 12:41:04 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:41:04.006Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
    Jan 07, 2019 12:41:06 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:41:04.113Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
    Jan 07, 2019 12:41:09 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:41:09.223Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/CreateDataflowView
    Jan 07, 2019 12:41:09 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2019-01-07T12:41:09.465Z: Executing operation Delete test files

STDERR: 
2019-01-07 12:58:34,565 c7861bcf 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_Compressed_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 719, in RunBenchmark
    DoRunPhase(spec, collector, detailed_timer)
  File "<https://builds.apache.org/job/beam_PerformanceTests_Compressed_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 580, in DoRunPhase
    samples = spec.BenchmarkRun(spec)
  File "<https://builds.apache.org/job/beam_PerformanceTests_Compressed_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_Compressed_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-01-07 12:58:34,567 c7861bcf MainThread beam_integration_benchmark(1/1) INFO     Cleaning
up benchmark beam_integration_benchmark
2019-01-07 12:58:34,570 c7861bcf MainThread beam_integration_benchmark(1/1) ERROR    Exception
running benchmark
Traceback (most recent call last):
  File "<https://builds.apache.org/job/beam_PerformanceTests_Compressed_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 860, in RunBenchmarkTask
    RunBenchmark(spec, collector)
  File "<https://builds.apache.org/job/beam_PerformanceTests_Compressed_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 719, in RunBenchmark
    DoRunPhase(spec, collector, detailed_timer)
  File "<https://builds.apache.org/job/beam_PerformanceTests_Compressed_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 580, in DoRunPhase
    samples = spec.BenchmarkRun(spec)
  File "<https://builds.apache.org/job/beam_PerformanceTests_Compressed_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_Compressed_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-01-07 12:58:34,571 c7861bcf MainThread beam_integration_benchmark(1/1) ERROR    Benchmark
1/1 beam_integration_benchmark (UID: beam_integration_benchmark0) failed. Execution will continue.
2019-01-07 12:58:34,571 c7861bcf 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-01-07 12:58:34,571 c7861bcf MainThread beam_integration_benchmark(1/1) INFO     Complete
logs can be found at: <https://builds.apache.org/job/beam_PerformanceTests_Compressed_TextIOIT/ws/runs/c7861bcf/pkb.log>
2019-01-07 12:58:34,572 c7861bcf MainThread beam_integration_benchmark(1/1) INFO     Completion
statuses can be found at: <https://builds.apache.org/job/beam_PerformanceTests_Compressed_TextIOIT/ws/runs/c7861bcf/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


Mime
View raw message