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/17 18:57:19 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow #316
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/316/display/redirect>
------------------------------------------
[...truncated 7.43 MB...]
INFO: Adding PAssert$13/GroupGlobally/GroupDummyAndContents as step s31
Dec 17, 2018 6:53:35 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/GroupGlobally/Values/Values/Map as step s32
Dec 17, 2018 6:53:35 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/GroupGlobally/ParDo(Concat) as step s33
Dec 17, 2018 6:53:35 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/GetPane/Map as step s34
Dec 17, 2018 6:53:35 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/RunChecks as step s35
Dec 17, 2018 6:53:35 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/VerifyAssertions/ParDo(DefaultConclude) as step s36
Dec 17, 2018 6:53:35 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging pipeline description to gs://temp-storage-for-end-to-end-tests/flattentest0testflattenpcollectionsemptythenpardo-jenkins-1217185325-71447b55/output/results/staging/
Dec 17, 2018 6:53:35 PM org.apache.beam.runners.dataflow.util.PackageUtil tryStagePackage
INFO: Uploading <77886 bytes, hash ANajbVmdsA1ipmYhfOqwIw> to gs://temp-storage-for-end-to-end-tests/flattentest0testflattenpcollectionsemptythenpardo-jenkins-1217185325-71447b55/output/results/staging/pipeline-ANajbVmdsA1ipmYhfOqwIw.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 17, 2018 6:53:37 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-17_10_53_35-15631031282121644180?project=apache-beam-testing
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_OUT
Submitted job: 2018-12-17_10_53_35-15631031282121644180
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_ERROR
Dec 17, 2018 6:53:37 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-17_10_53_35-15631031282121644180
Dec 17, 2018 6:53:37 PM org.apache.beam.runners.dataflow.TestDataflowRunner run
INFO: Running Dataflow job 2018-12-17_10_53_35-15631031282121644180 with 0 expected assertions.
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:36.135Z: Autoscaling is enabled for job 2018-12-17_10_53_35-15631031282121644180. The number of workers will be between 1 and 1000.
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:36.229Z: Autoscaling was automatically enabled for job 2018-12-17_10_53_35-15631031282121644180.
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2018-12-17T18:53:38.865Z: 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--gc3o. 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:39.187Z: Checking permissions granted to controller Service Account.
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:43.299Z: Worker configuration: n1-standard-1 in us-central1-b.
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:43.734Z: Expanding CollectionToSingleton operations into optimizable parts.
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:43.819Z: Expanding CoGroupByKey operations into optimizable parts.
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.063Z: Expanding GroupByKey operations into optimizable parts.
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.172Z: Fusing adjacent ParDo, Read, Write, and Flatten operations
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.219Z: Elided trivial flatten
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.267Z: Elided trivial flatten
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.314Z: Elided trivial flatten
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.363Z: Unzipping flatten s29 for input s17.org.apache.beam.sdk.values.PCollection.<init>:402#a4f9f304fed667ee
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.411Z: Fusing unzipped copy of PAssert$13/GroupGlobally/GroupDummyAndContents/Reify, through flatten PAssert$13/GroupGlobally/FlattenDummyAndContents, into producer PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.457Z: Fusing consumer PAssert$13/VerifyAssertions/ParDo(DefaultConclude) into PAssert$13/RunChecks
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.506Z: Unzipping flatten s29-u40 for input s31-reify-value18-c38
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.553Z: Fusing unzipped copy of PAssert$13/GroupGlobally/GroupDummyAndContents/Write, through flatten s29-u40, into producer PAssert$13/GroupGlobally/GroupDummyAndContents/Reify
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.602Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$13/GroupGlobally/GroupDummyAndContents/Read
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.649Z: Fusing consumer PAssert$13/GroupGlobally/Values/Values/Map into PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.696Z: Fusing consumer PAssert$13/GetPane/Map into PAssert$13/GroupGlobally/ParDo(Concat)
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.744Z: Fusing consumer PAssert$13/RunChecks into PAssert$13/GetPane/Map
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.790Z: Fusing consumer PAssert$13/GroupGlobally/ParDo(Concat) into PAssert$13/GroupGlobally/Values/Values/Map
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.827Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/Reify into PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.874Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/Write into PAssert$13/GroupGlobally/GroupDummyAndContents/Reify
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.934Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:44.978Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.019Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.054Z: Fusing consumer PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.094Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.136Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Read
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.182Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.223Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.262Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.310Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.355Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.403Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.447Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.491Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.523Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.573Z: Fusing consumer PAssert$13/GroupGlobally/Window.Into()/Window.Assign into ParDo(Identity)
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.616Z: Fusing consumer PAssert$13/GroupGlobally/RewindowActuals/Window.Assign into PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.650Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.696Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource) into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.749Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key into Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.818Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.899Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.939Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:45.982Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) into PAssert$13/GroupGlobally/Window.Into()/Window.Assign
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.032Z: Fusing consumer PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$13/GroupGlobally/RewindowActuals/Window.Assign
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.072Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.116Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource) into Flatten.PCollections/Create.Values/Read(CreateSource)/Impulse
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.157Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource) into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Impulse
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.196Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.243Z: Fusing consumer ParDo(Identity) into Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.846Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Create
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.901Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.952Z: Starting 1 workers in us-central1-b...
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:46.952Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Create
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:47.001Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Dec 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:47.368Z: 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 17, 2018 6:53:48 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:47.424Z: 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 17, 2018 6:53:59 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:53:59.364Z: Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
Dec 17, 2018 6:54:27 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:54:27.187Z: Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s).
Dec 17, 2018 6:54:27 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:54:27.234Z: Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
Dec 17, 2018 6:54:39 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:54:38.204Z: Workers have started successfully.
Dec 17, 2018 6:54:39 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:54:38.258Z: Workers have started successfully.
Dec 17, 2018 6:55:10 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:09.673Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Dec 17, 2018 6:55:10 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:09.823Z: 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 17, 2018 6:55:21 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:19.766Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Dec 17, 2018 6:55:21 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:19.895Z: 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 17, 2018 6:55:23 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:22.580Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Dec 17, 2018 6:55:23 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:22.741Z: 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 17, 2018 6:55:26 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:25.183Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Close
Dec 17, 2018 6:55:26 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:25.275Z: 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 17, 2018 6:55:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:31.695Z: Cleaning up.
Dec 17, 2018 6:55:33 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:55:31.823Z: Stopping worker pool...
Dec 17, 2018 6:57:06 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:57:06.108Z: Autoscaling: Resized worker pool from 1 to 0.
Dec 17, 2018 6:57:06 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:57:06.181Z: Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
Dec 17, 2018 6:57:06 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T18:57:06.287Z: Worker pool stopped.
Dec 17, 2018 6:57:14 PM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish
INFO: Job 2018-12-17_10_53_35-15631031282121644180 finished with status DONE.
Dec 17, 2018 6:57:15 PM org.apache.beam.runners.dataflow.TestDataflowRunner checkForPAssertSuccess
INFO: Success result for Dataflow job 2018-12-17_10_53_35-15631031282121644180. Found 0 success, 0 failures out of 0 expected assertions.
Gradle Test Executor 104 finished executing tests.
> Task :beam-runners-google-cloud-dataflow-java:validatesRunnerFnApiWorkerExecutableStageTest FAILED
72 tests completed, 7 failed, 1 skipped
Finished generating test XML results (0.216 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.347 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 37,5,main]) completed. Took 54 mins 1.691 secs.
:beam-runners-google-cloud-dataflow-java:cleanUpDockerImages (Thread[Task worker for ':' Thread 37,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:20181217180029
Successfully started process 'command 'docker''
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181217180029
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:d2e18a37372b7634686cc61d28b3770df6d90a39c9ef3f374e6847ca39d43c58
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:20181217180029
Successfully started process 'command 'gcloud''
Digests:
- us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:d2e18a37372b7634686cc61d28b3770df6d90a39c9ef3f374e6847ca39d43c58
Associated tags:
- 20181217180029
Tags:
- us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181217180029
Deleted [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181217180029].
Deleted [us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:d2e18a37372b7634686cc61d28b3770df6d90a39c9ef3f374e6847ca39d43c58].
:beam-runners-google-cloud-dataflow-java:cleanUpDockerImages (Thread[Task worker for ':' Thread 37,5,main]) completed. Took 2.311 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 57m 2s
75 actionable tasks: 68 executed, 6 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/rtomzlvkfpzpk
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 #318
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/318/display/redirect>
---------------------------------------------------------------------
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 #317
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_PortabilityApi_Dataflow/317/display/redirect?page=changes>
Changes:
[mxm] [BEAM-5419] Simplify job-server-container targets
------------------------------------------
[...truncated 8.06 MB...]
INFO: Adding PAssert$13/GroupGlobally/GroupDummyAndContents as step s31
Dec 17, 2018 7:56:56 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/GroupGlobally/Values/Values/Map as step s32
Dec 17, 2018 7:56:56 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/GroupGlobally/ParDo(Concat) as step s33
Dec 17, 2018 7:56:56 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/GetPane/Map as step s34
Dec 17, 2018 7:56:56 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/RunChecks as step s35
Dec 17, 2018 7:56:56 PM org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$13/VerifyAssertions/ParDo(DefaultConclude) as step s36
Dec 17, 2018 7:56:56 PM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging pipeline description to gs://temp-storage-for-end-to-end-tests/flattentest0testflattenpcollectionsemptythenpardo-jenkins-1217195636-2a621236/output/results/staging/
Dec 17, 2018 7:56:57 PM org.apache.beam.runners.dataflow.util.PackageUtil tryStagePackage
INFO: Uploading <77886 bytes, hash AWoINmLpIHBFIcGmAylHlQ> to gs://temp-storage-for-end-to-end-tests/flattentest0testflattenpcollectionsemptythenpardo-jenkins-1217195636-2a621236/output/results/staging/pipeline-AWoINmLpIHBFIcGmAylHlQ.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 17, 2018 7:56:58 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-17_11_56_57-6030555232518068540?project=apache-beam-testing
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_OUT
Submitted job: 2018-12-17_11_56_57-6030555232518068540
org.apache.beam.sdk.transforms.FlattenTest > testFlattenPCollectionsEmptyThenParDo STANDARD_ERROR
Dec 17, 2018 7:56:58 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-17_11_56_57-6030555232518068540
Dec 17, 2018 7:56:58 PM org.apache.beam.runners.dataflow.TestDataflowRunner run
INFO: Running Dataflow job 2018-12-17_11_56_57-6030555232518068540 with 0 expected assertions.
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:56:57.541Z: Autoscaling is enabled for job 2018-12-17_11_56_57-6030555232518068540. The number of workers will be between 1 and 1000.
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:56:57.581Z: Autoscaling was automatically enabled for job 2018-12-17_11_56_57-6030555232518068540.
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
WARNING: 2018-12-17T19:57:01.916Z: 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--mx8b. 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:32.570Z: Checking permissions granted to controller Service Account.
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:39.342Z: Worker configuration: n1-standard-1 in us-central1-b.
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:39.886Z: Expanding CollectionToSingleton operations into optimizable parts.
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:39.989Z: Expanding CoGroupByKey operations into optimizable parts.
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.204Z: Expanding GroupByKey operations into optimizable parts.
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.297Z: Fusing adjacent ParDo, Read, Write, and Flatten operations
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.344Z: Elided trivial flatten
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.391Z: Elided trivial flatten
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.438Z: Elided trivial flatten
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.483Z: Unzipping flatten s29 for input s17.org.apache.beam.sdk.values.PCollection.<init>:402#a4f9f304fed667ee
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.536Z: Fusing unzipped copy of PAssert$13/GroupGlobally/GroupDummyAndContents/Reify, through flatten PAssert$13/GroupGlobally/FlattenDummyAndContents, into producer PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.581Z: Fusing consumer PAssert$13/VerifyAssertions/ParDo(DefaultConclude) into PAssert$13/RunChecks
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.626Z: Unzipping flatten s29-u40 for input s31-reify-value18-c38
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.673Z: Fusing unzipped copy of PAssert$13/GroupGlobally/GroupDummyAndContents/Write, through flatten s29-u40, into producer PAssert$13/GroupGlobally/GroupDummyAndContents/Reify
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.723Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$13/GroupGlobally/GroupDummyAndContents/Read
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.766Z: Fusing consumer PAssert$13/GroupGlobally/Values/Values/Map into PAssert$13/GroupGlobally/GroupDummyAndContents/GroupByWindow
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.810Z: Fusing consumer PAssert$13/GetPane/Map into PAssert$13/GroupGlobally/ParDo(Concat)
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.854Z: Fusing consumer PAssert$13/RunChecks into PAssert$13/GetPane/Map
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.900Z: Fusing consumer PAssert$13/GroupGlobally/ParDo(Concat) into PAssert$13/GroupGlobally/Values/Values/Map
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:40.953Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/Reify into PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.011Z: Fusing consumer PAssert$13/GroupGlobally/GroupDummyAndContents/Write into PAssert$13/GroupGlobally/GroupDummyAndContents/Reify
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.057Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.113Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.168Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.214Z: Fusing consumer PAssert$13/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.258Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.295Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Read
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.343Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.388Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.425Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.472Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.513Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.583Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.635Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.689Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.728Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.774Z: Fusing consumer PAssert$13/GroupGlobally/Window.Into()/Window.Assign into ParDo(Identity)
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.822Z: Fusing consumer PAssert$13/GroupGlobally/RewindowActuals/Window.Assign into PAssert$13/GroupGlobally/GatherAllOutputs/Values/Values/Map
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.887Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.922Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource) into Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Values/Values/Map
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:41.955Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Pair with random key into Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource)
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.000Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.038Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.086Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.122Z: Fusing consumer PAssert$13/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) into PAssert$13/GroupGlobally/Window.Into()/Window.Assign
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.162Z: Fusing consumer PAssert$13/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$13/GroupGlobally/RewindowActuals/Window.Assign
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.211Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.258Z: Fusing consumer Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource) into Flatten.PCollections/Create.Values/Read(CreateSource)/Impulse
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.302Z: Fusing consumer PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/ParDo(SplitBoundedSource) into PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Impulse
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.363Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.413Z: Fusing consumer ParDo(Identity) into Flatten.PCollections/Create.Values/Read(CreateSource)/ParDo(ReadFromBoundedSource)
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.893Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Create
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.938Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.987Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Create
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:42.987Z: Starting 1 workers in us-central1-b...
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:43.038Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Create
Dec 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:43.311Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:43.363Z: 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 17, 2018 7:58:00 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:57:54.042Z: Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
Dec 17, 2018 7:58:23 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:58:23.071Z: Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s).
Dec 17, 2018 7:58:23 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:58:23.119Z: Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
Dec 17, 2018 7:58:26 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:58:24.499Z: Workers have started successfully.
Dec 17, 2018 7:58:26 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:58:24.582Z: Workers have started successfully.
Dec 17, 2018 7:58:58 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:58:56.999Z: Executing operation PAssert$13/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Dec 17, 2018 7:58:58 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:58:57.118Z: 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 17, 2018 7:59:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:59:06.167Z: Executing operation Flatten.PCollections/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Close
Dec 17, 2018 7:59:08 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:59:06.263Z: 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 17, 2018 7:59:10 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:59:09.072Z: Executing operation PAssert$13/GroupGlobally/GatherAllOutputs/GroupByKey/Close
Dec 17, 2018 7:59:10 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:59:09.162Z: 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 17, 2018 7:59:12 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:59:11.640Z: Executing operation PAssert$13/GroupGlobally/GroupDummyAndContents/Close
Dec 17, 2018 7:59:12 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:59:11.729Z: 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 17, 2018 7:59:23 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:59:22.901Z: Cleaning up.
Dec 17, 2018 7:59:24 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T19:59:23.008Z: Stopping worker pool...
Dec 17, 2018 8:01:09 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T20:01:08.763Z: Autoscaling: Resized worker pool from 1 to 0.
Dec 17, 2018 8:01:09 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T20:01:08.812Z: Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
Dec 17, 2018 8:01:09 PM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-12-17T20:01:08.867Z: Worker pool stopped.
Dec 17, 2018 8:01:15 PM org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish
INFO: Job 2018-12-17_11_56_57-6030555232518068540 finished with status DONE.
Dec 17, 2018 8:01:15 PM org.apache.beam.runners.dataflow.TestDataflowRunner checkForPAssertSuccess
INFO: Success result for Dataflow job 2018-12-17_11_56_57-6030555232518068540. Found 0 success, 0 failures out of 0 expected assertions.
Gradle Test Executor 118 finished executing tests.
> Task :beam-runners-google-cloud-dataflow-java:validatesRunnerFnApiWorkerExecutableStageTest FAILED
72 tests completed, 1 failed, 1 skipped
Finished generating test XML results (0.287 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.399 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 115,5,main]) completed. Took 54 mins 10.139 secs.
:beam-runners-google-cloud-dataflow-java:cleanUpDockerImages (Thread[Task worker for ':' Thread 115,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:20181217190413
Successfully started process 'command 'docker''
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181217190413
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:bd5cb11ef1968743d5cbb9168317dcc57f913e51c6c14b186be23aa1cac2cc98
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:20181217190413
Successfully started process 'command 'gcloud''
Digests:
- us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:bd5cb11ef1968743d5cbb9168317dcc57f913e51c6c14b186be23aa1cac2cc98
Associated tags:
- 20181217190413
Tags:
- us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181217190413
Deleted [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20181217190413].
Deleted [us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:bd5cb11ef1968743d5cbb9168317dcc57f913e51c6c14b186be23aa1cac2cc98].
:beam-runners-google-cloud-dataflow-java:cleanUpDockerImages (Thread[Task worker for ':' Thread 115,5,main]) completed. Took 2.366 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 57m 17s
75 actionable tasks: 69 executed, 5 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/cnpvupswviosu
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