You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/12/28 12:45:24 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow #395
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/395/display/redirect>
------------------------------------------
[...truncated 8.01 MB...]
INFO: Adding PAssert$13/GroupGlobally/GroupDummyAndContents as step s31
Dec 28, 2018 12:39:53 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/GroupGlobally/Values/Values/Map as step s32
Dec 28, 2018 12:39:53 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/GroupGlobally/ParDo(Concat) as step s33
Dec 28, 2018 12:39:53 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/GetPane/Map as step s34
Dec 28, 2018 12:39:53 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/RunChecks as step s35
Dec 28, 2018 12:39:53 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/VerifyAssertions/ParDo(DefaultConclude) as step s36
Dec 28, 2018 12:39:53 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging pipeline description to gs://temp-storage-for-end-to-end-tests/flattentest0testflattenpcollectionsemptythenpardo-jenkins-1228123944-a33f0f0e/output/results/staging/
Dec 28, 2018 12:39:53 PM org.apache.beam.runners.dataflow.util.PackageUtil tryStagePackage
INFO: Uploading <77877 bytes, hash snptCgDQuHaQF7PWLMOYVw> to gs://temp-storage-for-end-to-end-tests/flattentest0testflattenpcollectionsemptythenpardo-jenkins-1228123944-a33f0f0e/output/results/staging/pipeline-snptCgDQuHaQF7PWLMOYVw.pb
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_OUT
Dataflow SDK version: 2.10.0-SNAPSHOT
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_ERROR
Dec 28, 2018 12:39:55 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To access the Dataflow monitoring console, please navigate to https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2018-12-28_04_39_53-5701319525022159215?project=apache-beam-testing
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_OUT
Submitted job: 2018-12-28_04_39_53-5701319525022159215
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_ERROR
Dec 28, 2018 12:39:55 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To cancel the job using the 'gcloud' tool, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel --region=us-central1 2018-12-28_04_39_53-5701319525022159215
Dec 28, 2018 12:39:55 PM org.apache.beam.runners.dataflow.TestDataflowRunner run
INFO: Running Dataflow job 2018-12-28_04_39_53-5701319525022159215 with 0 expected assertions.
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:39:54.127Z: Autoscaling is enabled for job 2018-12-28_04_39_53-5701319525022159215. The number of workers will be between 1 and 1000.
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:39:54.234Z: Autoscaling was automatically enabled for job 2018-12-28_04_39_53-5701319525022159215.
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2018-12-28T12:39:56.860Z: The workflow name is not a valid Cloud Label. Labels applied to Cloud resources (such as GCE Instances) for monitoring will be labeled with this modified job name: flattentest0testflattenpcollectionsemptythenpardo-jenkins--n3ab. For the best monitoring experience, please name your job with a valid Cloud Label. For details, see: https://cloud.google.com/compute/docs/labeling-resources#restrictions
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:39:57.181Z: Checking permissions granted to controller Service Account.
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:00.954Z: Worker configuration: n1-standard-1 in us-central1-b.
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:01.469Z: Expanding CollectionToSingleton operations into optimizable parts.
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:01.557Z: Expanding CoGroupByKey operations into optimizable parts.
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:01.947Z: Expanding GroupByKey operations into optimizable parts.
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.053Z: Fusing adjacent ParDo, Read, Write, and Flatten operations
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.093Z: Elided trivial flatten
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.130Z: Elided trivial flatten
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.167Z: Elided trivial flatten
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.215Z: Unzipping flatten s29 for input s17.org.apache.beam.sdk.values.PCollection.<init>:402#a4f9f304fed667ee
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.259Z: Fusing unzipped copy of PAssert$13/GroupGlobally/GroupDummyAndContents/Reify, through flatten PAssert$13/GroupGlobally/FlattenDummyAndContents, into producer PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.300Z: Fusing consumer PAssert$13/VerifyAssertions/ParDo(DefaultConclude) into PAssert$13/RunChecks
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.336Z: Unzipping flatten s29-u40 for input s31-reify-value18-c38
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.379Z: Fusing unzipped copy of PAssert$13/GroupGlobally/GroupDummyAndContents/Write, through flatten s29-u40, into producer PAssert$13/GroupGlobally/GroupDummyAndContents/Reify
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.426Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$13/GroupGlobally/GroupDummyAndContents/Read
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.471Z: Fusing consumer PAssert$13/GroupGlobally/Values/Values/Map into PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.516Z: Fusing consumer PAssert$13/GetPane/Map into PAssert$13/GroupGlobally/ParDo(Concat)
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.563Z: Fusing consumer PAssert$13/RunChecks into PAssert$13/GetPane/Map
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.611Z: Fusing consumer PAssert$13/GroupGlobally/ParDo(Concat) into PAssert$13/GroupGlobally/Values/Values/Map
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.655Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/Reify into PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.695Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/Write into PAssert$13/GroupGlobally/GroupDummyAndContents/Reify
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.742Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.786Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.832Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.877Z: Fusing consumer PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.923Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:02.963Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Read
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.006Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.050Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource) into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.096Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.145Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.186Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.230Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.286Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.332Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.371Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.418Z: Fusing consumer PAssert$13/GroupGlobally/Window.Into()/Window.Assign into ParDo(Identity)
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.460Z: Fusing consumer PAssert$13/GroupGlobally/RewindowActuals/Window.Assign into PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.506Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.546Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource) into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.592Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key into Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.638Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.676Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.721Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.768Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) into PAssert$13/GroupGlobally/Window.Into()/Window.Assign
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.799Z: Fusing consumer PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$13/GroupGlobally/RewindowActuals/Window.Assign
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.852Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.893Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource) into Flatten.PCollections/Create.Values/Read(CreateSource)/Impulse
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.937Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource) into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Impulse
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:03.979Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:04.026Z: Fusing consumer ParDo(Identity) into Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:04.467Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Create
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:04.515Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:04.553Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Create
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:04.564Z: Starting 1 workers in us-central1-b...
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:04.589Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:04.831Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Impulse+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
Dec 28, 2018 12:40:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:04.886Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Impulse+Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
Dec 28, 2018 12:40:21 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:40:21.248Z: Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
Dec 28, 2018 12:41:19 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:41:17.711Z: Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s).
Dec 28, 2018 12:41:19 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:41:17.755Z: Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
Dec 28, 2018 12:41:35 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:41:34.418Z: Workers have started successfully.
Dec 28, 2018 12:41:35 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:41:34.461Z: Workers have started successfully.
Dec 28, 2018 12:42:24 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:23.290Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Dec 28, 2018 12:42:24 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:23.395Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)+PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$13/GroupGlobally/GroupDummyAndContents/Reify+PAssert$13/GroupGlobally/GroupDummyAndContents/Write
Dec 28, 2018 12:42:34 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:33.323Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Dec 28, 2018 12:42:34 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:33.439Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map+Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)+ParDo(Identity)+PAssert$13/GroupGlobally/Window.Into()/Window.Assign+PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Dec 28, 2018 12:42:36 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:36.077Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Dec 28, 2018 12:42:36 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:36.169Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$13/GroupGlobally/RewindowActuals/Window.Assign+PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$13/GroupGlobally/GroupDummyAndContents/Reify+PAssert$13/GroupGlobally/GroupDummyAndContents/Write
Dec 28, 2018 12:42:39 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:38.710Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Close
Dec 28, 2018 12:42:39 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:38.827Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Read+PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$13/GroupGlobally/Values/Values/Map+PAssert$13/GroupGlobally/ParDo(Concat)+PAssert$13/GetPane/Map+PAssert$13/RunChecks+PAssert$13/VerifyAssertions/ParDo(DefaultConclude)
Dec 28, 2018 12:42:47 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:46.336Z: Cleaning up.
Dec 28, 2018 12:42:47 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:42:46.444Z: Stopping worker pool...
Dec 28, 2018 12:45:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:45:14.921Z: Autoscaling: Resized worker pool from 1 to 0.
Dec 28, 2018 12:45:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:45:14.964Z: Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
Dec 28, 2018 12:45:17 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T12:45:15.037Z: Worker pool stopped.
Dec 28, 2018 12:45:20 PM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish
INFO: Job 2018-12-28_04_39_53-5701319525022159215 finished with status DONE.
Dec 28, 2018 12:45:20 PM org.apache.beam.runners.dataflow.TestDataflowRunner checkForPAssertSuccess
INFO: Success result for Dataflow job 2018-12-28_04_39_53-5701319525022159215. Found 0 success, 0 failures out of 0 expected assertions.
Gradle Test Executor 119 finished executing tests.
> Task :beam-runners-google-cloud-dataflow-java:validatesRunnerFnApiWorkerExecutableStageTest FAILED
71 tests completed, 1 failed, 1 skipped
Finished generating test XML results (0.159 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java/build/test-results/validatesRunnerFnApiWorkerExecutableStageTest>
Generating HTML test report...
Finished generating test html results (0.271 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java/build/reports/tests/validatesRunnerFnApiWorkerExecutableStageTest>
:beam-runners-google-cloud-dataflow-java:validatesRunnerFnApiWorkerExecutableStageTest (Thread[Task worker for ':' Thread 48,5,main]) completed. Took 55 mins 23.38 secs.
:beam-runners-google-cloud-dataflow-java:cleanUpDockerImages (Thread[Task worker for ':' Thread 48,5,main]) started.
> Task :beam-runners-google-cloud-dataflow-java:cleanUpDockerImages
Caching disabled for task ':beam-runners-google-cloud-dataflow-java:cleanUpDockerImages': Caching has not been enabled for the task
Task ':beam-runners-google-cloud-dataflow-java:cleanUpDockerImages' is not up-to-date because:
Task has not declared any outputs despite executing actions.
Starting process 'command 'docker''. Working directory: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java> Command: docker rmi us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228114724
Successfully started process 'command 'docker''
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228114724
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:09412b9a964be7fb922f900b9a14386cbcbce605377ddc204d2ef89006c86c4c
Starting process 'command 'gcloud''. Working directory: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java> Command: gcloud --quiet container images delete --force-delete-tags us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228114724
Successfully started process 'command 'gcloud''
Digests:
- us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:09412b9a964be7fb922f900b9a14386cbcbce605377ddc204d2ef89006c86c4c
Associated tags:
- 20181228114724
Tags:
- us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228114724
Deleted [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228114724].
Deleted [us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:09412b9a964be7fb922f900b9a14386cbcbce605377ddc204d2ef89006c86c4c].
:beam-runners-google-cloud-dataflow-java:cleanUpDockerImages (Thread[Task worker for ':' Thread 48,5,main]) completed. Took 1.85 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-google-cloud-dataflow-java:validatesRunnerFnApiWorkerExecutableStageTest'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java/build/reports/tests/validatesRunnerFnApiWorkerExecutableStageTest/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 58m 7s
76 actionable tasks: 70 executed, 5 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/vkvcta6lokflo
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal :
beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow #397
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/397/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow #396
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/396/display/redirect>
------------------------------------------
[...truncated 7.96 MB...]
INFO: Adding PAssert$13/VerifyAssertions/ParDo(DefaultConclude) as step s36
Dec 28, 2018 1:37:36 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging pipeline description to gs://temp-storage-for-end-to-end-tests/flattentest0testflattenpcollectionsemptythenpardo-jenkins-1228133727-db94f678/output/results/staging/
Dec 28, 2018 1:37:36 PM org.apache.beam.runners.dataflow.util.PackageUtil tryStagePackage
INFO: Uploading <77877 bytes, hash 6HK5MjcyoNIk-j6vdMhy2A> to gs://temp-storage-for-end-to-end-tests/flattentest0testflattenpcollectionsemptythenpardo-jenkins-1228133727-db94f678/output/results/staging/pipeline-6HK5MjcyoNIk-j6vdMhy2A.pb
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_OUT
Dataflow SDK version: 2.10.0-SNAPSHOT
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_ERROR
Dec 28, 2018 1:37:38 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To access the Dataflow monitoring console, please navigate to https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2018-12-28_05_37_37-4781966158834836775?project=apache-beam-testing
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_OUT
Submitted job: 2018-12-28_05_37_37-4781966158834836775
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_ERROR
Dec 28, 2018 1:37:38 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: To cancel the job using the 'gcloud' tool, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel --region=us-central1 2018-12-28_05_37_37-4781966158834836775
Dec 28, 2018 1:37:38 PM org.apache.beam.runners.dataflow.TestDataflowRunner run
INFO: Running Dataflow job 2018-12-28_05_37_37-4781966158834836775 with 0 expected assertions.
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:37.178Z: Autoscaling is enabled for job 2018-12-28_05_37_37-4781966158834836775. The number of workers will be between 1 and 1000.
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:37.222Z: Autoscaling was automatically enabled for job 2018-12-28_05_37_37-4781966158834836775.
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2018-12-28T13:37:40.199Z: The workflow name is not a valid Cloud Label. Labels applied to Cloud resources (such as GCE Instances) for monitoring will be labeled with this modified job name: flattentest0testflattenpcollectionsemptythenpardo-jenkins--sfyh. For the best monitoring experience, please name your job with a valid Cloud Label. For details, see: https://cloud.google.com/compute/docs/labeling-resources#restrictions
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:40.517Z: Checking permissions granted to controller Service Account.
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:44.362Z: Worker configuration: n1-standard-1 in us-central1-b.
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:44.970Z: Expanding CollectionToSingleton operations into optimizable parts.
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.053Z: Expanding CoGroupByKey operations into optimizable parts.
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.294Z: Expanding GroupByKey operations into optimizable parts.
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.398Z: Fusing adjacent ParDo, Read, Write, and Flatten operations
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.438Z: Elided trivial flatten
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.483Z: Elided trivial flatten
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.524Z: Elided trivial flatten
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.575Z: Unzipping flatten s29 for input s17.org.apache.beam.sdk.values.PCollection.<init>:402#a4f9f304fed667ee
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.621Z: Fusing unzipped copy of PAssert$13/GroupGlobally/GroupDummyAndContents/Reify, through flatten PAssert$13/GroupGlobally/FlattenDummyAndContents, into producer PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.662Z: Fusing consumer PAssert$13/VerifyAssertions/ParDo(DefaultConclude) into PAssert$13/RunChecks
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.707Z: Unzipping flatten s29-u40 for input s31-reify-value18-c38
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.749Z: Fusing unzipped copy of PAssert$13/GroupGlobally/GroupDummyAndContents/Write, through flatten s29-u40, into producer PAssert$13/GroupGlobally/GroupDummyAndContents/Reify
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.792Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$13/GroupGlobally/GroupDummyAndContents/Read
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.830Z: Fusing consumer PAssert$13/GroupGlobally/Values/Values/Map into PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.877Z: Fusing consumer PAssert$13/GetPane/Map into PAssert$13/GroupGlobally/ParDo(Concat)
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.925Z: Fusing consumer PAssert$13/RunChecks into PAssert$13/GetPane/Map
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:45.971Z: Fusing consumer PAssert$13/GroupGlobally/ParDo(Concat) into PAssert$13/GroupGlobally/Values/Values/Map
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.018Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/Reify into PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.056Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/Write into PAssert$13/GroupGlobally/GroupDummyAndContents/Reify
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.104Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.148Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.196Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.232Z: Fusing consumer PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.273Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.322Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Read
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.372Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.409Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource) into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.445Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.486Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.534Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.579Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.622Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.665Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.714Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.763Z: Fusing consumer PAssert$13/GroupGlobally/Window.Into()/Window.Assign into ParDo(Identity)
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.812Z: Fusing consumer PAssert$13/GroupGlobally/RewindowActuals/Window.Assign into PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.859Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.902Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource) into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.946Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key into Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:46.994Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.041Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.085Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.133Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) into PAssert$13/GroupGlobally/Window.Into()/Window.Assign
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.182Z: Fusing consumer PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$13/GroupGlobally/RewindowActuals/Window.Assign
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.229Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.278Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource) into Flatten.PCollections/Create.Values/Read(CreateSource)/Impulse
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.326Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource) into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Impulse
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.375Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.422Z: Fusing consumer ParDo(Identity) into Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.899Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Create
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.939Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.982Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Create
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:47.993Z: Starting 1 workers in us-central1-b...
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:48.030Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:48.238Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Impulse+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
Dec 28, 2018 1:37:51 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:48.289Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Impulse+Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Write
Dec 28, 2018 1:38:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:37:59.967Z: Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
Dec 28, 2018 1:38:29 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:38:28.207Z: Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s).
Dec 28, 2018 1:38:29 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:38:28.325Z: Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
Dec 28, 2018 1:38:44 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:38:43.390Z: Workers have started successfully.
Dec 28, 2018 1:38:44 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:38:43.435Z: Workers have started successfully.
Dec 28, 2018 1:39:07 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:06.657Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Dec 28, 2018 1:39:07 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:06.738Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable+Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map+Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)+ParDo(Identity)+PAssert$13/GroupGlobally/Window.Into()/Window.Assign+PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Write
Dec 28, 2018 1:39:10 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:09.501Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Dec 28, 2018 1:39:10 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:09.570Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$13/GroupGlobally/RewindowActuals/Window.Assign+PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$13/GroupGlobally/GroupDummyAndContents/Reify+PAssert$13/GroupGlobally/GroupDummyAndContents/Write
Dec 28, 2018 1:39:14 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:14.687Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Dec 28, 2018 1:39:14 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:14.779Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map+PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)+PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$13/GroupGlobally/GroupDummyAndContents/Reify+PAssert$13/GroupGlobally/GroupDummyAndContents/Write
Dec 28, 2018 1:39:22 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:22.082Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Close
Dec 28, 2018 1:39:22 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:22.167Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Read+PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$13/GroupGlobally/Values/Values/Map+PAssert$13/GroupGlobally/ParDo(Concat)+PAssert$13/GetPane/Map+PAssert$13/RunChecks+PAssert$13/VerifyAssertions/ParDo(DefaultConclude)
Dec 28, 2018 1:39:31 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:29.834Z: Cleaning up.
Dec 28, 2018 1:39:31 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:39:29.925Z: Stopping worker pool...
Dec 28, 2018 1:41:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:41:53.242Z: Autoscaling: Resized worker pool from 1 to 0.
Dec 28, 2018 1:41:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:41:53.289Z: Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
Dec 28, 2018 1:41:54 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-28T13:41:53.348Z: Worker pool stopped.
Dec 28, 2018 1:41:59 PM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish
INFO: Job 2018-12-28_05_37_37-4781966158834836775 finished with status DONE.
Dec 28, 2018 1:41:59 PM org.apache.beam.runners.dataflow.TestDataflowRunner checkForPAssertSuccess
INFO: Success result for Dataflow job 2018-12-28_05_37_37-4781966158834836775. Found 0 success, 0 failures out of 0 expected assertions.
Gradle Test Executor 119 finished executing tests.
> Task :beam-runners-google-cloud-dataflow-java:validatesRunnerFnApiWorkerExecutableStageTest FAILED
71 tests completed, 2 failed, 1 skipped
Finished generating test XML results (0.16 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java/build/test-results/validatesRunnerFnApiWorkerExecutableStageTest>
Generating HTML test report...
Finished generating test html results (0.229 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java/build/reports/tests/validatesRunnerFnApiWorkerExecutableStageTest>
:beam-runners-google-cloud-dataflow-java:validatesRunnerFnApiWorkerExecutableStageTest (Thread[Task worker for ':' Thread 20,5,main]) completed. Took 53 mins 42.998 secs.
:beam-runners-google-cloud-dataflow-java:cleanUpDockerImages (Thread[Task worker for ':' Thread 41,5,main]) started.
> Task :beam-runners-google-cloud-dataflow-java:cleanUpDockerImages
Caching disabled for task ':beam-runners-google-cloud-dataflow-java:cleanUpDockerImages': Caching has not been enabled for the task
Task ':beam-runners-google-cloud-dataflow-java:cleanUpDockerImages' is not up-to-date because:
Task has not declared any outputs despite executing actions.
Starting process 'command 'docker''. Working directory: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java> Command: docker rmi us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228124549
Successfully started process 'command 'docker''
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228124549
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:b463470fdb14ce0251a8435c0e032ab24081138bb75065e2cb700a54fc62d599
Deleted: sha256:73bf93b760f2bc6018702541d1182e50b6830b34712b66d063816ce76e0a0a88
Deleted: sha256:28098bf9f5a398aea595fbd249e7ad9014ea19b21c4cb0c70c31676cb9af7667
Deleted: sha256:29b426a13806349f63276f732b8fb84f007db41455d8d0ddfe417c8f85a4e0c4
Deleted: sha256:0ef561abe3c7fcb110d1a9df3dfb2048bb83d85a41a6d6088cc7235b517b4e30
Deleted: sha256:fd9ab5de01ec95b66a499247d795e098ee79c377611d13e2d42f94a9749c6185
Deleted: sha256:3e8db0b050d75ea7cd2b588b2f24d079d5663a5174db00026021203668669232
Deleted: sha256:80dd2226d782bd345502636a459e7a99e1db958f1b914f6d4ef643d401c43412
Deleted: sha256:85cfaf35fda1a01859c8790affd4f8a88a44355443a155475a837d2013bbdefe
Deleted: sha256:87308e7c3a154cf18c1fc716a230f2899cb0e9c5372261b9a4f3bd5eadd51f77
Deleted: sha256:51e1258d344aaa69ff65818ca4fabbfaaa89badd67d97f696710e5cf4ce4126d
Starting process 'command 'gcloud''. Working directory: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java> Command: gcloud --quiet container images delete --force-delete-tags us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228124549
Successfully started process 'command 'gcloud''
Digests:
- us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:b463470fdb14ce0251a8435c0e032ab24081138bb75065e2cb700a54fc62d599
Associated tags:
- 20181228124549
Tags:
- us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228124549
Deleted [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181228124549].
Deleted [us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:b463470fdb14ce0251a8435c0e032ab24081138bb75065e2cb700a54fc62d599].
:beam-runners-google-cloud-dataflow-java:cleanUpDockerImages (Thread[Task worker for ':' Thread 41,5,main]) completed. Took 1.923 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-google-cloud-dataflow-java:validatesRunnerFnApiWorkerExecutableStageTest'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/ws/src/runners/google-cloud-dataflow-java/build/reports/tests/validatesRunnerFnApiWorkerExecutableStageTest/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 56m 23s
76 actionable tasks: 70 executed, 5 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/nxcgedvnvukgg
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org