See
<https://builds.apache.org/job/beam_PerformanceTests_TextIOIT/1204/display/redirect?page=changes>
Changes:
[markliu] Refactor Python integration test build script
[markliu] [BEAM-5462] fix pipeline.option since it's deprecated
[amaliujia] [BEAM-5852] add IS_INF and IS_NAN.
[amaliujia] [BEAM-5885] support COSH
[amaliujia] [BEAM-5889] support SINH
[amaliujia] [BEAM-5890] add TANH
[amaliujia] [SQL] spotless apply
[amaliujia] [BEAM-5892] add annotation to help register built-in functions.
[robinyqiu] Create a wrapper around tox as a workaround to the Nose-related bug
in
[amaliujia] [SQL] improve beam builtin function registration.
[vojtech.janota] BEAM-5933: avoid memory allocation in hashCode call
[scott] Add switch to disable spotless for Java projects
[scott] Add separate Spotless pre-commit and disable spotless on other Java
------------------------------------------
[...truncated 258.61 KB...]
INFO: 2018-11-01T18:28:00.471Z: Unzipping flatten s43-c110 for input
s38.org.apache.beam.sdk.values.PCollection.<init>:402#361385b10c542cfa
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.519Z: Fusing unzipped copy of
PAssert$0/CreateActual/FilterActuals/Window.Assign, through flatten Calculate
hashcode/Flatten.PCollections, into producer Calculate
hashcode/Values/Values/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.556Z: Fusing consumer
PAssert$0/CreateActual/ExtractPane/Map into
PAssert$0/CreateActual/GatherPanes/Values/Values/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.595Z: Fusing consumer
PAssert$0/CreateActual/GatherPanes/GroupByKey/Reify into
PAssert$0/CreateActual/GatherPanes/Window.Into()/Window.Assign
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.644Z: Fusing consumer
PAssert$0/CreateActual/GatherPanes/GroupByKey/Write into
PAssert$0/CreateActual/GatherPanes/GroupByKey/Reify
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.684Z: Fusing consumer
PAssert$0/CreateActual/GatherPanes/GroupByKey/GroupByWindow into
PAssert$0/CreateActual/GatherPanes/GroupByKey/Read
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.735Z: Fusing consumer
View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
into
View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.779Z: Fusing consumer
PAssert$0/CreateActual/ParDo(Anonymous) into
PAssert$0/CreateActual/RewindowActuals/Window.Assign
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.825Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.875Z: Fusing consumer
View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
into
View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.924Z: Unzipping flatten s43 for input
s38.org.apache.beam.sdk.values.PCollection.<init>:402#361385b10c542cfa
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:00.973Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.012Z: Unzipping flatten s43-u118 for input
s45.org.apache.beam.sdk.values.PCollection.<init>:402#f64a260e30cc43cd-c116
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.060Z: Fusing unzipped copy of
PAssert$0/CreateActual/GatherPanes/WithKeys/AddKeys/Map, through flatten
s43-u118, into producer
PAssert$0/CreateActual/GatherPanes/Reify.Window/ParDo(Anonymous)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.102Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.148Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.193Z: Fusing consumer
View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
into
View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.235Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.282Z: Unzipping flatten s43-u123 for input
s66.org.apache.beam.sdk.values.PCollection.<init>:402#4ed21626b69b8d5f-c121
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.331Z: 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 s43-u123, into producer
View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.378Z: Fusing consumer
PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
into PAssert$0/CreateActual/ParDo(Anonymous)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.427Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.481Z: Unzipping flatten s43-u123-u136 for input
partial-s67-out1-c134
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.525Z: Fusing unzipped copy of
View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify,
through flatten s43-u123-u136, 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.565Z: Fusing consumer
PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
into
PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.613Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.665Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.714Z: 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)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.754Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.802Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.857Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.892Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.937Z: Fusing consumer
PAssert$0/CreateActual/FilterActuals/Window.Assign into Calculate
hashcode/ProduceDefault
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:01.992Z: Fusing consumer
View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
into Calculate hashcode/ProduceDefault
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.039Z: Fusing consumer Read all
files/FileIO.MatchAll/Match filepatterns into Values/Values/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.090Z: Fusing consumer Calculate
hashcode/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow) into Calculate
hashcode/Values/Values/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.141Z: Fusing consumer
PAssert$0/CreateActual/GatherPanes/WithKeys/AddKeys/Map into
PAssert$0/CreateActual/GatherPanes/Reify.Window/ParDo(Anonymous)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.176Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.240Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.291Z: Fusing consumer Read all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Values/Values/Map into Read all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.338Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Write into Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Reify
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.388Z: Fusing consumer Calculate
hashcode/WithKeys/AddKeys/Map into Read all files/TextIO.ReadFiles/Read all via
FileBasedSource/Read ranges
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.436Z: Fusing consumer Read all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable into Read
all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.475Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Reify into Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.526Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey+Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Partial into Calculate
hashcode/WithKeys/AddKeys/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.567Z: Fusing consumer Write content to
files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map
into Write content to
files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.612Z: Fusing consumer Read all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
into Read all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.661Z: Fusing consumer Read all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write into
Read all files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.708Z: Fusing consumer Write content to
files/WriteFiles/FinalizeTempFileBundles/Finalize into Write content to
files/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.755Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.805Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.847Z: Fusing consumer Calculate
hashcode/ProduceDefault into Calculate hashcode/CreateVoid/Read(CreateSource)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.899Z: Fusing consumer Calculate
hashcode/Values/Values/Map into Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.941Z: 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)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:02.995Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.037Z: 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)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.083Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.132Z: Fusing consumer Read all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Pair with random key into Read all
files/FileIO.MatchAll/Match filepatterns
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.182Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.231Z: Fusing consumer Values/Values/Map into
Write content to
files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.268Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues/Extract into Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.319Z: Fusing consumer Calculate
hashcode/Combine.perKey(Hashing)/Combine.GroupedValues into Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Read
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.361Z: Fusing consumer Read all
files/TextIO.ReadFiles/Read all via FileBasedSource/Split into ranges into Read
all files/FileIO.ReadMatches/ParDo(ToReadableFile)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.396Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.436Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.486Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.535Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.580Z: Fusing consumer Read all
files/FileIO.ReadMatches/ParDo(ToReadableFile) into Read all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Values/Values/Map
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.628Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.672Z: Fusing consumer Write content to
files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
into Write content to
files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.722Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.773Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.825Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.875Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.911Z: Fusing consumer Write content to
files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair with
random key into Write content to
files/WriteFiles/FinalizeTempFileBundles/Finalize
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:03.958Z: Unzipping flatten s8 for input
s4.writtenRecords
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.001Z: 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
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.035Z: Fusing consumer Write content to
files/WriteFiles/GatherTempFileResults/View.AsList/ParDo(ToIsmRecordForGlobalWindow)
into Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.086Z: Fusing consumer Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Reify into
Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.133Z: Fusing consumer Produce text lines into
Generate sequence/Read(BoundedCountingSource)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.185Z: Fusing consumer Write content to
files/WriteFiles/RewindowIntoGlobal/Window.Assign into Produce text lines
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.223Z: Fusing consumer Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/GroupByWindow
into Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Read
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.265Z: Fusing consumer Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum into Write
content to files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.312Z: Fusing consumer Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten into Write
content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/GroupByWindow
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.409Z: Fusing consumer Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Write into
Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Reify
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.461Z: Fusing consumer Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles into
Write content to files/WriteFiles/RewindowIntoGlobal/Window.Assign
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.511Z: Fusing consumer
PAssert$0/WindowToken/Window.Assign into
PAssert$0/Create.Values/Read(CreateSource)
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.556Z: Fusing consumer
PAssert$0/VerifyAssertions/ParDo(DefaultConclude) into PAssert$0/RunChecks
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:04.603Z: Fusing consumer PAssert$0/RunChecks into
PAssert$0/WindowToken/Window.Assign
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.165Z: Executing operation Write content to
files/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.216Z: Executing operation Read all
files/FileIO.MatchAll/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.261Z: Executing operation Read all
files/TextIO.ReadFiles/Read all via
FileBasedSource/Reshuffle/Reshuffle/GroupByKey/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.273Z: Starting 1 workers in us-central1-b...
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.304Z: Executing operation Calculate
hashcode/Combine.perKey(Hashing)/GroupByKey/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.352Z: Executing operation
PAssert$0/CreateActual/GatherPanes/GroupByKey/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.399Z: Executing operation Write content to
files/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.450Z: Executing operation
PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.499Z: Executing operation
PAssert$0/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.556Z: Executing operation
View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:05.604Z: Executing operation
View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
Nov 01, 2018 6:28:09 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:06.122Z: 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
Nov 01, 2018 6:28:18 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:28:16.728Z: Autoscaling: Raised the number of workers
to 0 based on the rate of progress in the currently running step(s).
Nov 01, 2018 6:29:05 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:29:03.996Z: Workers have started successfully.
Nov 01, 2018 6:29:26 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:29:24.818Z: Autoscaling: Raised the number of workers
to 1 based on the rate of progress in the currently running step(s).
Nov 01, 2018 6:29:26 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:29:24.863Z: Autoscaling: Would further reduce the
number of workers but reached the minimum number allowed for the job.
Nov 01, 2018 6:36:40 PM
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-11-01T18:36:38.621Z: Workers have started successfully.
STDERR:
2018-11-01 18:46:03,462 378b2aec 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_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
line 719, in RunBenchmark
DoRunPhase(spec, collector, detailed_timer)
File
"<https://builds.apache.org/job/beam_PerformanceTests_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
line 580, in DoRunPhase
samples = spec.BenchmarkRun(spec)
File
"<https://builds.apache.org/job/beam_PerformanceTests_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_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/providers/gcp/gcp_dpb_dataflow.py";,>
line 90, in SubmitJob
assert retcode == 0, "Integration Test Failed."
AssertionError: Integration Test Failed.
2018-11-01 18:46:03,464 378b2aec MainThread beam_integration_benchmark(1/1)
INFO Cleaning up benchmark beam_integration_benchmark
2018-11-01 18:46:03,466 378b2aec MainThread beam_integration_benchmark(1/1)
ERROR Exception running benchmark
Traceback (most recent call last):
File
"<https://builds.apache.org/job/beam_PerformanceTests_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
line 860, in RunBenchmarkTask
RunBenchmark(spec, collector)
File
"<https://builds.apache.org/job/beam_PerformanceTests_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
line 719, in RunBenchmark
DoRunPhase(spec, collector, detailed_timer)
File
"<https://builds.apache.org/job/beam_PerformanceTests_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
line 580, in DoRunPhase
samples = spec.BenchmarkRun(spec)
File
"<https://builds.apache.org/job/beam_PerformanceTests_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_TextIOIT/ws/PerfKitBenchmarker/perfkitbenchmarker/providers/gcp/gcp_dpb_dataflow.py";,>
line 90, in SubmitJob
assert retcode == 0, "Integration Test Failed."
AssertionError: Integration Test Failed.
2018-11-01 18:46:03,467 378b2aec MainThread beam_integration_benchmark(1/1)
ERROR Benchmark 1/1 beam_integration_benchmark (UID:
beam_integration_benchmark0) failed. Execution will continue.
2018-11-01 18:46:03,502 378b2aec MainThread INFO Benchmark run statuses:
---------------------------------------------------------------------------------
Name UID Status Failed
Substatus
---------------------------------------------------------------------------------
beam_integration_benchmark beam_integration_benchmark0 FAILED
---------------------------------------------------------------------------------
Success rate: 0.00% (0/1)
2018-11-01 18:46:03,503 378b2aec MainThread INFO Complete logs can be found
at:
<https://builds.apache.org/job/beam_PerformanceTests_TextIOIT/ws/runs/378b2aec/pkb.log>
2018-11-01 18:46:03,503 378b2aec MainThread INFO Completion statuses can be
found at:
<https://builds.apache.org/job/beam_PerformanceTests_TextIOIT/ws/runs/378b2aec/completion_statuses.json>
Build step 'Execute shell' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
