beam-commits 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_ParquetIOIT_HDFS #366
Date Wed, 12 Sep 2018 06:48:23 GMT
See <https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/366/display/redirect?page=changes>

Changes:

[relax] Add convenience methods to create TopCombineFns. Type-specific methods

[relax] Allow Coders to be explicitly specified in composed CombineFns for the

[relax] Apply spotless.

[relax] Address comments.

[relax] Revert unexpected changes.

------------------------------------------
[...truncated 254.00 KB...]
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.319Z: Fusing unzipped copy of PAssert$0/CreateActual/GatherPanes/GroupByKey/Reify,
through flatten s44-u131, into producer PAssert$0/CreateActual/GatherPanes/Window.Into()/Window.Assign
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.363Z: Fusing consumer PAssert$0/CreateActual/GatherPanes/GroupByKey/Reify
into PAssert$0/CreateActual/GatherPanes/Window.Into()/Window.Assign
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.405Z: Fusing consumer PAssert$0/CreateActual/GatherPanes/Values/Values/Map
into PAssert$0/CreateActual/GatherPanes/GroupByKey/GroupByWindow
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.451Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
into PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.494Z: Unzipping flatten s44 for input s39.org.apache.beam.sdk.values.PCollection.<init>:384#3a4fe559e568642
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.538Z: Fusing unzipped copy of View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map,
through flatten Calculate hashcode/Flatten.PCollections, into producer Calculate hashcode/Values/Values/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.580Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
into Calculate hashcode/ProduceDefault
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.626Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
into View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.665Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.702Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.734Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.779Z: Unzipping flatten s44-u140 for input s67.org.apache.beam.sdk.values.PCollection.<init>:384#81b732087dcb45c4-c138
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.825Z: Fusing unzipped copy of View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial,
through flatten s44-u140, into producer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.868Z: 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
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.908Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:36.954Z: Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues
into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.029Z: Unzipping flatten s44-u140-u145 for input partial-s68-out1-c143
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.077Z: Fusing unzipped copy of View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify,
through flatten s44-u140-u145, into producer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.114Z: 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
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.155Z: Fusing consumer PAssert$0/CreateActual/ExtractPane/Map
into PAssert$0/CreateActual/GatherPanes/Values/Values/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.197Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
into PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.224Z: 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
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.268Z: 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)
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.302Z: 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
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.348Z: 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
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.393Z: 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
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.438Z: Fusing consumer PAssert$0/CreateActual/Flatten.Iterables/FlattenIterables/FlatMap
into PAssert$0/CreateActual/ExtractPane/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.477Z: Fusing consumer PAssert$0/CreateActual/ParDo(Anonymous)
into PAssert$0/CreateActual/RewindowActuals/Window.Assign
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.523Z: 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
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.563Z: 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
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.607Z: Fusing consumer PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
into PAssert$0/CreateActual/ParDo(Anonymous)
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.646Z: Fusing consumer PAssert$0/CreateActual/RewindowActuals/Window.Assign
into PAssert$0/CreateActual/Flatten.Iterables/FlattenIterables/FlatMap
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.681Z: Fusing consumer Calculate hashcode/ProduceDefault into
Calculate hashcode/CreateVoid/Read(CreateSource)
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.717Z: Fusing consumer Find files/Match filepatterns into Get
file names/Values/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.745Z: Fusing consumer Calculate hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)
into Calculate hashcode/Values/Values/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.790Z: Fusing consumer Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
into Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.827Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial into Calculate hashcode/WithKeys/AddKeys/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.873Z: Fusing consumer Calculate hashcode/WithKeys/AddKeys/Map
into Map records to strings/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.908Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/GroupByKey/GroupByWindow
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/GroupByKey/Read
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.943Z: Fusing consumer Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
into Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:37.988Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.032Z: Fusing consumer Map records to strings/Map into Read parquet
files/ParDo(Read)
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.067Z: Fusing consumer Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
into Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.111Z: Fusing consumer Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
into Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair with
random key
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.156Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/GroupByKey/Write
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/GroupByKey/Reify
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.192Z: Fusing consumer Calculate hashcode/Values/Values/Map into
Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.230Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract
into Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.275Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues
into Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Read
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.320Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Write
into Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Reify
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.366Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/Window.Into()/Window.Assign
into Write Parquet files/WriteFiles/GatherTempFileResults/Add void key/AddKeys/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.411Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/GroupByKey/Reify
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/Window.Into()/Window.Assign
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.441Z: Fusing consumer Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair
with random key into Write Parquet files/WriteFiles/FinalizeTempFileBundles/Finalize
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.486Z: Fusing consumer Write Parquet files/WriteFiles/FinalizeTempFileBundles/Finalize
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Values/Values/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.531Z: Fusing consumer Find files/Reshuffle.ViaRandomKey/Values/Values/Map
into Find files/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.577Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.623Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.665Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Values/Values/Map
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.710Z: Fusing consumer Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Reify
into Calculate hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.754Z: Fusing consumer Find files/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
into Find files/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.784Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.829Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Gather
bundles into Write Parquet files/WriteFiles/GatherTempFileResults/Drop key/Values/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.860Z: Fusing consumer Find files/Reshuffle.ViaRandomKey/Pair
with random key into Find files/Match filepatterns
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.905Z: Fusing consumer Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
into Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.947Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/ExpandIterable
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/GroupByKey/GroupByWindow
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:38.984Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Drop
key/Values/Map into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/ExpandIterable
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.026Z: Fusing consumer Read parquet files/ParDo(Read) into Read
matched files/ParDo(ToReadableFile)
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.068Z: Fusing consumer Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map
into Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.113Z: Fusing consumer Read matched files/ParDo(ToReadableFile)
into Find files/Reshuffle.ViaRandomKey/Values/Values/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.157Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
into Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Pair with
random key
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.194Z: Fusing consumer Find files/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
into Find files/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.239Z: Fusing consumer Find files/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
into Find files/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.275Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Pair
with random key into Write Parquet files/WriteFiles/GatherTempFileResults/Gather bundles
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.320Z: Fusing consumer Find files/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
into Find files/Reshuffle.ViaRandomKey/Pair with random key
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.354Z: Fusing consumer Find files/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
into Find files/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.388Z: Fusing consumer Get file names/Values/Map into Write Parquet
files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.434Z: Unzipping flatten s8 for input s4.writtenRecords
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.480Z: Fusing unzipped copy of Write Parquet files/WriteFiles/GatherTempFileResults/Add
void key/AddKeys/Map, through flatten Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/Flatten.PCollections,
into producer Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.515Z: Fusing consumer Write Parquet files/WriteFiles/GatherTempFileResults/Add
void key/AddKeys/Map into Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.559Z: Fusing consumer Produce text lines into Generate sequence/Read(BoundedCountingSource)
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.603Z: Fusing consumer Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/GroupByWindow
into Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Read
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.648Z: Fusing consumer Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten
into Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/GroupByWindow
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.682Z: Fusing consumer Produce Avro records into Produce text
lines
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.721Z: Fusing consumer Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Write
into Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Reify
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.755Z: Fusing consumer Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles
into Produce Avro records
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.800Z: Fusing consumer Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Reify
into Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.844Z: Fusing consumer Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum
into Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.880Z: Fusing consumer PAssert$0/VerifyAssertions/ParDo(DefaultConclude)
into PAssert$0/RunChecks
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.914Z: Fusing consumer PAssert$0/WindowToken/Window.Assign into
PAssert$0/Create.Values/Read(CreateSource)
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:39.955Z: Fusing consumer PAssert$0/RunChecks into PAssert$0/WindowToken/Window.Assign
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.417Z: Executing operation Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/GroupByKey/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.442Z: Executing operation Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.475Z: Executing operation Write Parquet files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.510Z: Executing operation Find files/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.510Z: Starting 1 workers in us-central1-b...
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.546Z: Executing operation Calculate hashcode/Combine.perKey(Hashing)/GroupByKey/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.602Z: Executing operation PAssert$0/CreateActual/GatherPanes/GroupByKey/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.635Z: Executing operation Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.669Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.702Z: Executing operation PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.738Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:40.770Z: Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
    Sep 12, 2018 6:28:43 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:41.170Z: Executing operation Generate sequence/Read(BoundedCountingSource)+Produce
text lines+Produce Avro records+Write Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles+Write
Parquet files/WriteFiles/GatherTempFileResults/Add void key/AddKeys/Map+Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/Window.Into()/Window.Assign+Write
Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/GroupByKey/Reify+Write Parquet files/WriteFiles/GatherTempFileResults/Reshuffle/GroupByKey/Write+Write
Parquet files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Reify+Write Parquet
files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Write
    Sep 12, 2018 6:28:54 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:28:52.156Z: Autoscaling: Raised the number of workers to 0 based on
the rate of progress in the currently running step(s).
    Sep 12, 2018 6:31:23 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:31:22.120Z: Autoscaling: Raised the number of workers to 1 based on
the rate of progress in the currently running step(s).
    Sep 12, 2018 6:31:23 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler
process
    INFO: 2018-09-12T06:31:22.164Z: Autoscaling: Would further reduce the number of workers
but reached the minimum number allowed for the job.

STDERR: 
2018-09-12 06:46:33,226 94ddb361 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_ParquetIOIT_HDFS/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 695, in RunBenchmark
    DoRunPhase(spec, collector, detailed_timer)
  File "<https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 575, in DoRunPhase
    samples = spec.BenchmarkRun(spec)
  File "<https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/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_ParquetIOIT_HDFS/ws/PerfKitBenchmarker/perfkitbenchmarker/providers/gcp/gcp_dpb_dataflow.py",>
line 90, in SubmitJob
    assert retcode == 0, "Integration Test Failed."
AssertionError: Integration Test Failed.
2018-09-12 06:46:33,227 94ddb361 MainThread beam_integration_benchmark(1/1) INFO     Cleaning
up benchmark beam_integration_benchmark
2018-09-12 06:46:33,228 94ddb361 MainThread beam_integration_benchmark(1/1) INFO     Running:
kubectl --kubeconfig=<https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/ws/config-beam-performancetests-parquetioit-hdfs-366>
delete -f <https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/ws/src/.test-infra/kubernetes/hadoop/LargeITCluster/hdfs-multi-datanode-cluster.yml>
--ignore-not-found
2018-09-12 06:48:23,053 94ddb361 MainThread beam_integration_benchmark(1/1) ERROR    Exception
running benchmark
Traceback (most recent call last):
  File "<https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 831, in RunBenchmarkTask
    RunBenchmark(spec, collector)
  File "<https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 695, in RunBenchmark
    DoRunPhase(spec, collector, detailed_timer)
  File "<https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py",>
line 575, in DoRunPhase
    samples = spec.BenchmarkRun(spec)
  File "<https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/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_ParquetIOIT_HDFS/ws/PerfKitBenchmarker/perfkitbenchmarker/providers/gcp/gcp_dpb_dataflow.py",>
line 90, in SubmitJob
    assert retcode == 0, "Integration Test Failed."
AssertionError: Integration Test Failed.
2018-09-12 06:48:23,054 94ddb361 MainThread beam_integration_benchmark(1/1) ERROR    Benchmark
1/1 beam_integration_benchmark (UID: beam_integration_benchmark0) failed. Execution will continue.
2018-09-12 06:48:23,098 94ddb361 MainThread INFO     Benchmark run statuses:
---------------------------------------------------------------------------------
Name                        UID                          Status  Failed Substatus
---------------------------------------------------------------------------------
beam_integration_benchmark  beam_integration_benchmark0  FAILED                  
---------------------------------------------------------------------------------
Success rate: 0.00% (0/1)
2018-09-12 06:48:23,100 94ddb361 MainThread INFO     Complete logs can be found at: <https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/ws/runs/94ddb361/pkb.log>
2018-09-12 06:48:23,100 94ddb361 MainThread INFO     Completion statuses can be found at:
<https://builds.apache.org/job/beam_PerformanceTests_ParquetIOIT_HDFS/ws/runs/94ddb361/completion_statuses.json>
Build step 'Execute shell' marked build as failure

Mime
View raw message