You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2017/11/16 01:11:00 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Dataflow #4353
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4353/display/redirect?page=changes>
Changes:
[lcwik] [BEAM-2926] Migrate to using a trivial multimap materialization within
[lcwik] Rebase and update code to honor findbugs @Nullable/@Nonnull conversion
[lcwik] Update Dataflow worker image to be compatible with side input changes.
[lcwik] Replace the View.As transforms for Dataflow batch because the entire
[lcwik] Fix BatchViewOverrides ViewAsSingleton to apply the combine fn that was
[altay] Fixed adding timestamp and id attributes to pubsub messages
------------------------------------------
[...truncated 21.27 MB...]
[INFO] 2017-11-16T01:07:12.197Z: (f4d735c7217f8aaa): Executing operation PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-16T01:07:12.238Z: (f4d735c7217f80b2): Executing operation PAssert$329/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-16T01:07:12.320Z: (9f36a581300e2be9): Executing operation PAssert$329/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$329/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$329/GroupGlobally/GroupDummyAndContents/Reify+PAssert$329/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:07:12.343Z: (f4d735c7217f86fd): Executing operation PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$329/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$329/GroupGlobally/RewindowActuals/Window.Assign+PAssert$329/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$329/GroupGlobally/GroupDummyAndContents/Reify+PAssert$329/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:07:11.638Z: (134835db3fdb31d8): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-16T01:07:11.711Z: (2e8a9cf405956b57): Executing operation Create.Values/Read(CreateSource)+Combine.perKey(MeanInts)/GroupByKey+Combine.perKey(MeanInts)/Combine.GroupedValues/Partial+Values/Values/Map+Combine.globally(MeanInts)/WithKeys/AddKeys/Map+Combine.globally(MeanInts)/Combine.perKey(MeanInts)/GroupByKey+Combine.globally(MeanInts)/Combine.perKey(MeanInts)/Combine.GroupedValues/Partial+Combine.perKey(MeanInts)/GroupByKey/Reify+Combine.perKey(MeanInts)/GroupByKey/Write+Combine.globally(MeanInts)/Combine.perKey(MeanInts)/GroupByKey/Reify+Combine.globally(MeanInts)/Combine.perKey(MeanInts)/GroupByKey/Write
[INFO] 2017-11-16T01:07:10.870Z: (14f0a72e609d7c6b): Unzipping flatten s11-c153 for input s10.10
[INFO] 2017-11-16T01:07:10.873Z: (14f0a72e609d7bd9): Fusing unzipped copy of View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map, through flatten , into producer Sum/ProduceDefault
[INFO] 2017-11-16T01:07:10.876Z: (14f0a72e609d7b47): Unzipping flatten s11 for input s10.10
[INFO] 2017-11-16T01:07:10.879Z: (14f0a72e609d7ab5): Fusing unzipped copy of PAssert$333/GroupGlobally/Window.Into()/Window.Assign, through flatten , into producer Sum/ProduceDefault
[INFO] 2017-11-16T01:07:10.881Z: (14f0a72e609d7a23): Fusing consumer PAssert$333/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
[INFO] 2017-11-16T01:07:10.884Z: (14f0a72e609d7991): Fusing consumer PAssert$333/GroupGlobally/RewindowActuals/Window.Assign into PAssert$333/GroupGlobally/GatherAllOutputs/Values/Values/Map
[INFO] 2017-11-16T01:07:10.887Z: (14f0a72e609d78ff): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map into Sum/Values/Values/Map
[INFO] 2017-11-16T01:07:10.889Z: (14f0a72e609d786d): Fusing consumer PAssert$333/GroupGlobally/Window.Into()/Window.Assign into Sum/Values/Values/Map
[INFO] 2017-11-16T01:07:10.894Z: (14f0a72e609d77db): Unzipping flatten s11-u171 for input s28.28-c169
[INFO] 2017-11-16T01:07:10.898Z: (14f0a72e609d7749): Fusing unzipped copy of PAssert$333/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign, through flatten , into producer PAssert$333/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
[INFO] 2017-11-16T01:07:10.901Z: (14f0a72e609d76b7): Fusing consumer PAssert$333/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$333/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
[INFO] 2017-11-16T01:07:10.903Z: (14f0a72e609d7625): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
[INFO] 2017-11-16T01:07:10.906Z: (14f0a72e609d7593): Fusing consumer Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract into Sum/Combine.perKey(SumInts)/Combine.GroupedValues
[INFO] 2017-11-16T01:07:10.908Z: (14f0a72e609d7501): Fusing consumer Sum/Values/Values/Map into Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract
[INFO] 2017-11-16T01:07:10.910Z: (14f0a72e609d746f): Fusing consumer Sum/Combine.perKey(SumInts)/Combine.GroupedValues into Sum/Combine.perKey(SumInts)/GroupByKey/Read
[INFO] 2017-11-16T01:07:10.912Z: (14f0a72e609d73dd): Fusing consumer Sum/Combine.perKey(SumInts)/GroupByKey+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Partial into Sum/WithKeys/AddKeys/Map
[INFO] 2017-11-16T01:07:10.915Z: (14f0a72e609d734b): Fusing consumer PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Read
[INFO] 2017-11-16T01:07:10.916Z: (14f0a72e609d72b9): Fusing consumer PAssert$335/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$335/GroupGlobally/RewindowActuals/Window.Assign
[INFO] 2017-11-16T01:07:10.920Z: (14f0a72e609d7227): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$335/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
[INFO] 2017-11-16T01:07:10.924Z: (14f0a72e609d7195): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
[INFO] 2017-11-16T01:07:10.926Z: (14f0a72e609d7103): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Read
[INFO] 2017-11-16T01:07:10.929Z: (14f0a72e609d7071): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues
[INFO] 2017-11-16T01:07:11.168Z: (61625076f9d4146f): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Create
[INFO] 2017-11-16T01:07:11.184Z: (a2cd916f7245f337): Starting 1 workers in us-central1-f...
[INFO] 2017-11-16T01:07:11.264Z: (7bfeb95524164973): Executing operation Create.Values/Read(CreateSource)+Values/Values/Map+Sum/WithKeys/AddKeys/Map+Sum/Combine.perKey(SumInts)/GroupByKey+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Partial+Sum/Combine.perKey(SumInts)/GroupByKey/Reify+Sum/Combine.perKey(SumInts)/GroupByKey/Write
[INFO] 2017-11-16T01:07:14.821Z: (7520729cc9ac1964): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-16T01:07:14.855Z: (7520729cc9ac145c): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-16T01:07:14.947Z: (8b2dd38758adaf53): Executing operation PAssert$325/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$325/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$325/GroupGlobally/GroupDummyAndContents/Reify+PAssert$325/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:07:14.984Z: (7520729cc9ac1971): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$325/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$325/GroupGlobally/RewindowActuals/Window.Assign+PAssert$325/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$325/GroupGlobally/GroupDummyAndContents/Reify+PAssert$325/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:07:16.861Z: (9c9eee2df21c18a6): Autoscaling: Resizing worker pool from 1 to 2.
[INFO] 2017-11-16T01:07:17.261Z: (9f36a581300e26df): Executing operation PAssert$329/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-16T01:07:17.292Z: (9f36a581300e245a): Executing operation PAssert$329/GroupGlobally/GroupDummyAndContents/Read+PAssert$329/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$329/GroupGlobally/Values/Values/Map+PAssert$329/GroupGlobally/ParDo(Concat)+PAssert$329/GetPane/Map+PAssert$329/RunChecks+PAssert$329/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-16T01:07:16.831Z: (a38194a91f26ffd): Executing operation PAssert$324/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-16T01:07:16.868Z: (a38194a91f2662a): Executing operation PAssert$324/GroupGlobally/GroupDummyAndContents/Read+PAssert$324/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$324/GroupGlobally/Values/Values/Map+PAssert$324/GroupGlobally/ParDo(Concat)+PAssert$324/GetPane/Map+PAssert$324/RunChecks+PAssert$324/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-16T01:07:19.153Z: (b008ef6cf4a11461): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-16T01:07:22.994Z: (134835db3fdb38fc): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-16T01:07:22.998Z: (134835db3fdb305a): Resized worker pool to 1, though goal was 2. This could be a quota issue.
[INFO] 2017-11-16T01:07:22.630Z: (7520729cc9ac161f): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-16T01:07:22.665Z: (8b2dd38758adab25): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Read+PAssert$325/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$325/GroupGlobally/Values/Values/Map+PAssert$325/GroupGlobally/ParDo(Concat)+PAssert$325/GetPane/Map+PAssert$325/RunChecks+PAssert$325/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-16T01:07:23.247Z: (835892a27ce7a5b4): Cleaning up.
[INFO] 2017-11-16T01:07:23.275Z: (835892a27ce7ad0e): Stopping worker pool...
[INFO] 2017-11-16T01:07:24.212Z: (b51c0087736e49f9): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-16T01:07:24.216Z: (b51c0087736e42bf): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-16T01:07:24.315Z: (25cfe8972c28ec2c): Cleaning up.
[INFO] 2017-11-16T01:07:24.346Z: (25cfe8972c28e7f2): Stopping worker pool...
[INFO] 2017-11-16T01:07:26.283Z: (7e6da708d5b035bc): Autoscaling: Resized worker pool from 2 to 0.
[INFO] 2017-11-16T01:07:26.285Z: (7e6da708d5b031da): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-16T01:07:26.290Z: (1ea881e71fc92b5e): Worker pool stopped.
[INFO] 2017-11-16T01:07:29.585Z: (b008ef6cf4a11ab2): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-16T01:07:30.382Z: (6fbcfc6937d3d3de): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close
[INFO] 2017-11-16T01:07:30.988Z: (5992896711a87ea3): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-16T01:07:30.993Z: (5992896711a87a25): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-15_17_04_13-10534443594570288116 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_04_13-10534443594570288116. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] 2017-11-16T01:07:30.417Z: (6fbcfc6937d3df16): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-16T01:07:30.492Z: (6fbcfc6937d3db22): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+Combine.globally(TestCombineFnWithContext)/Values/Values/Map+PAssert$327/GroupGlobally/Window.Into()/Window.Assign+PAssert$327/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$327/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$327/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-16T01:07:33.755Z: (6fbcfc6937d3d802): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-16T01:07:33.782Z: (8b2dd38758ada133): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-16T01:07:33.853Z: (8b2dd38758ada45f): Executing operation PAssert$327/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$327/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$327/GroupGlobally/GroupDummyAndContents/Reify+PAssert$327/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:07:33.878Z: (6fbcfc6937d3d33a): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$327/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$327/GroupGlobally/RewindowActuals/Window.Assign+PAssert$327/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$327/GroupGlobally/GroupDummyAndContents/Reify+PAssert$327/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:07:35.809Z: (3a1700465082bcb0): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-16T01:07:35.811Z: (3a1700465082b4fa): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-15_17_04_48-7142584956770951408 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_04_48-7142584956770951408. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-16T01:07:37.401Z: (8b2dd38758ada1a2): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-16T01:07:37.434Z: (8b2dd38758ada78b): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Read+PAssert$327/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$327/GroupGlobally/Values/Values/Map+PAssert$327/GroupGlobally/ParDo(Concat)+PAssert$327/GetPane/Map+PAssert$327/RunChecks+PAssert$327/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-16T01:07:38.713Z: (134835db3fdb3a06): Autoscaling: Raised the number of workers to 2 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-16T01:07:41.126Z: (8d12ea58a6462e4a): Cleaning up.
[INFO] 2017-11-16T01:07:41.169Z: (8d12ea58a64623b0): Stopping worker pool...
[INFO] Job 2017-11-15_17_04_50-14580801458864092724 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_04_50-14580801458864092724. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-16T01:07:47.404Z: (552cd37aed2efe58): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-16T01:07:47.407Z: (552cd37aed2ef38e): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-15_17_04_45-14575047663192943567 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_04_45-14575047663192943567. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-16T01:07:49.764Z: (3167e9baa243306d): Workers have started successfully.
[INFO] 2017-11-16T01:07:50.551Z: (be6957b93b365ffb): Workers have started successfully.
[INFO] 2017-11-16T01:07:50.713Z: (8a1dab3dbcd826e7): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-16T01:07:50.714Z: (8a1dab3dbcd82cd1): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-16T01:07:52.347Z: (89ec390164d8a99c): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-16T01:07:52.349Z: (89ec390164d8ae8a): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-15_17_04_02-12558957163458255851 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_04_02-12558957163458255851. Found 4 success, 0 failures out of 4 expected assertions.
[INFO] Job 2017-11-15_17_05_15-13292520519259131295 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_05_15-13292520519259131295. Found 1 success, 0 failures out of 1 expected assertions.
[INFO] Job 2017-11-15_17_04_14-1367359309177398311 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_04_14-1367359309177398311. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] 2017-11-16T01:07:59.497Z: (8c57de699a4dd8c0): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-16T01:07:59.499Z: (8c57de699a4ddf22): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-15_17_04_50-4400244364415606832 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_04_50-4400244364415606832. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] 2017-11-16T01:08:08.467Z: (cd1415db60213f41): Executing operation Combine.perKey(MeanInts)/GroupByKey/Close
[INFO] 2017-11-16T01:08:08.492Z: (2e8a9cf405956562): Executing operation Combine.globally(MeanInts)/Combine.perKey(MeanInts)/GroupByKey/Close
[INFO] 2017-11-16T01:08:08.523Z: (cd1415db60213bbe): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-16T01:08:08.554Z: (2e8a9cf40595678a): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-16T01:08:08.639Z: (cd1415db60213062): Executing operation Combine.perKey(MeanInts)/GroupByKey/Read+Combine.perKey(MeanInts)/Combine.GroupedValues+Combine.perKey(MeanInts)/Combine.GroupedValues/Extract+PAssert$332/GroupGlobally/Window.Into()/Window.Assign+PAssert$332/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$332/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$332/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-16T01:08:08.669Z: (2e8a9cf405956f33): Executing operation Combine.globally(MeanInts)/Combine.perKey(MeanInts)/GroupByKey/Read+Combine.globally(MeanInts)/Combine.perKey(MeanInts)/Combine.GroupedValues+Combine.globally(MeanInts)/Combine.perKey(MeanInts)/Combine.GroupedValues/Extract+Combine.globally(MeanInts)/Values/Values/Map+PAssert$331/GroupGlobally/Window.Into()/Window.Assign+PAssert$331/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+Combine.globally(MeanInts)/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+PAssert$331/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$331/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-16T01:08:11.778Z: (e281b5999124c520): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-16T01:08:11.810Z: (cd1415db6021395c): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-16T01:08:11.908Z: (e281b5999124ccf8): Executing operation PAssert$332/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$332/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$332/GroupGlobally/GroupDummyAndContents/Reify+PAssert$332/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:08:11.931Z: (cd1415db60213e00): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$332/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$332/GroupGlobally/RewindowActuals/Window.Assign+PAssert$332/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$332/GroupGlobally/GroupDummyAndContents/Reify+PAssert$332/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:08:13.166Z: (7bfeb9552416420b): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Close
[INFO] 2017-11-16T01:08:13.206Z: (7bfeb955241640ec): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
[INFO] 2017-11-16T01:08:13.238Z: (fe3f48ac4f2e0): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-16T01:08:13.334Z: (7bfeb955241648f9): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Read+Sum/Combine.perKey(SumInts)/Combine.GroupedValues+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract+Sum/Values/Values/Map+Sum/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write+PAssert$333/GroupGlobally/Window.Into()/Window.Assign+PAssert$333/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$333/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$333/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-16T01:08:17.249Z: (cd1415db602136fa): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-16T01:08:17.357Z: (7bfeb955241640af): Executing operation Sum/View.AsIterable/CreateDataflowView
[INFO] 2017-11-16T01:08:17.444Z: (7bfeb955241649db): Executing operation Sum/CreateVoid/Read(CreateSource)+Sum/ProduceDefault+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write+PAssert$333/GroupGlobally/Window.Into()/Window.Assign+PAssert$333/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$333/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$333/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-16T01:08:19.143Z: (fc86fd7df1e6754d): Autoscaling: Resizing worker pool from 1 to 2.
[INFO] 2017-11-16T01:08:17.274Z: (e281b5999124c7b7): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Read+PAssert$332/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$332/GroupGlobally/Values/Values/Map+PAssert$332/GroupGlobally/ParDo(Concat)+PAssert$332/GetPane/Map+PAssert$332/RunChecks+PAssert$332/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-16T01:08:21.149Z: (fe3f48ac4fd87): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
[INFO] 2017-11-16T01:08:21.178Z: (7bfeb95524164e1a): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-16T01:08:21.203Z: (fe3f48ac4ffff): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
[INFO] 2017-11-16T01:08:21.233Z: (7bfeb95524164ee2): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-16T01:08:21.318Z: (fe3f48ac4ffdc): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
[INFO] 2017-11-16T01:08:21.349Z: (7bfeb955241648d6): Executing operation PAssert$333/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$333/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$333/GroupGlobally/GroupDummyAndContents/Reify+PAssert$333/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:08:21.382Z: (bd1c343bcb5c5b83): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$333/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$333/GroupGlobally/RewindowActuals/Window.Assign+PAssert$333/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$333/GroupGlobally/GroupDummyAndContents/Reify+PAssert$333/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:08:21.214Z: (b4e8c77ca8f99a75): Autoscaling: Resized worker pool from 2 to 0.
[INFO] 2017-11-16T01:08:21.216Z: (b4e8c77ca8f99fd7): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-16T01:08:24.671Z: (b008ef6cf4a11f3b): Autoscaling: Raised the number of workers to 2 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-16T01:08:23.965Z: (2e8a9cf4059564fd): Executing operation Combine.globally(MeanInts)/View.AsIterable/CreateDataflowView
[INFO] 2017-11-16T01:08:24.046Z: (2e8a9cf405956039): Executing operation Combine.globally(MeanInts)/CreateVoid/Read(CreateSource)+Combine.globally(MeanInts)/ProduceDefault+PAssert$331/GroupGlobally/Window.Into()/Window.Assign+PAssert$331/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$331/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$331/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-16T01:08:25.202Z: (a10655a2cebd34bb): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-16T01:08:25.204Z: (a10655a2cebd3f65): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-16T01:08:26.171Z: (2e8a9cf4059567e2): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-16T01:08:26.210Z: (e281b5999124ce62): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-16T01:08:26.289Z: (e281b5999124cb2b): Executing operation PAssert$331/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$331/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$331/GroupGlobally/GroupDummyAndContents/Reify+PAssert$331/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:08:26.320Z: (2e8a9cf405956677): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$331/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$331/GroupGlobally/RewindowActuals/Window.Assign+PAssert$331/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$331/GroupGlobally/GroupDummyAndContents/Reify+PAssert$331/GroupGlobally/GroupDummyAndContents/Write
[INFO] Job 2017-11-15_17_05_51-6902807729869364974 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_05_51-6902807729869364974. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-16T01:08:31.555Z: (e281b5999124c5ea): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-16T01:08:31.594Z: (2e8a9cf405956f51): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Read+PAssert$331/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$331/GroupGlobally/Values/Values/Map+PAssert$331/GroupGlobally/ParDo(Concat)+PAssert$331/GetPane/Map+PAssert$331/RunChecks+PAssert$331/VerifyAssertions/ParDo(DefaultConclude)
[INFO] Job 2017-11-15_17_04_58-256038449576245136 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_04_58-256038449576245136. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] 2017-11-16T01:08:33.284Z: (96cb2ccb1e6c624b): Cleaning up.
[INFO] 2017-11-16T01:08:33.308Z: (96cb2ccb1e6c64f1): Stopping worker pool...
[INFO] 2017-11-16T01:08:32.864Z: (965c859369771c17): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-16T01:08:32.869Z: (965c859369771ae5): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-16T01:08:35.944Z: (632d976349c432c8): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
[INFO] 2017-11-16T01:08:35.974Z: (fe3f48ac4f16a): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
[INFO] Job 2017-11-15_17_04_55-16347122873472209321 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_04_55-16347122873472209321. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] 2017-11-16T01:08:45.226Z: (a9d9672ae79ca3e4): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-16T01:08:45.268Z: (a9d9672ae79ca5e3): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Read+PAssert$333/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$333/GroupGlobally/Values/Values/Map+PAssert$333/GroupGlobally/ParDo(Concat)+PAssert$333/GetPane/Map+PAssert$333/RunChecks+PAssert$333/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-16T01:08:55.117Z: (fe3f48ac4fa60): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/CreateDataflowView
[INFO] 2017-11-16T01:08:55.190Z: (fe3f48ac4f7c5): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create
[INFO] 2017-11-16T01:08:55.201Z: (a9d9672ae79ca102): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create
[INFO] 2017-11-16T01:08:55.337Z: (bd1c343bcb5c5e11): Executing operation Combine.globally(TestCombineFnWithContext)/WithKeys/AddKeys/Map+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write
[INFO] 2017-11-16T01:08:55.354Z: (fe3f48ac4fa1a): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write
[INFO] 2017-11-16T01:08:55.912Z: (9fa844cafca8195e): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close
[INFO] 2017-11-16T01:08:55.939Z: (fe3f48ac4f90d): Executing operation PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-16T01:08:56.012Z: (9fa844cafca81231): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+PAssert$334/GroupGlobally/Window.Into()/Window.Assign+PAssert$334/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$334/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$334/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-16T01:08:58.245Z: (fe3f48ac4f4c1): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close
[INFO] 2017-11-16T01:08:58.276Z: (fe3f48ac4f739): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-16T01:08:58.345Z: (bd1c343bcb5c5556): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+Combine.globally(TestCombineFnWithContext)/Values/Values/Map+PAssert$335/GroupGlobally/Window.Into()/Window.Assign+PAssert$335/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$335/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$335/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-16T01:09:00.341Z: (9fa844cafca81534): Executing operation PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-16T01:09:00.383Z: (9fa844cafca81a4c): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-16T01:09:00.485Z: (fe3f48ac4f47b): Executing operation PAssert$334/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$334/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$334/GroupGlobally/GroupDummyAndContents/Reify+PAssert$334/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:09:00.510Z: (9fa844cafca81b4d): Executing operation PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$334/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$334/GroupGlobally/RewindowActuals/Window.Assign+PAssert$334/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$334/GroupGlobally/GroupDummyAndContents/Reify+PAssert$334/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:09:01.500Z: (bd1c343bcb5c59bf): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-16T01:09:01.546Z: (bd1c343bcb5c5407): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-16T01:09:01.639Z: (a9d9672ae79ca66d): Executing operation PAssert$335/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$335/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$335/GroupGlobally/GroupDummyAndContents/Reify+PAssert$335/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:09:01.657Z: (bd1c343bcb5c55bb): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$335/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$335/GroupGlobally/RewindowActuals/Window.Assign+PAssert$335/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$335/GroupGlobally/GroupDummyAndContents/Reify+PAssert$335/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-16T01:09:04.749Z: (bd1c343bcb5c50dd): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-16T01:09:04.794Z: (bd1c343bcb5c5fdc): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Read+PAssert$335/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$335/GroupGlobally/Values/Values/Map+PAssert$335/GroupGlobally/ParDo(Concat)+PAssert$335/GetPane/Map+PAssert$335/RunChecks+PAssert$335/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-16T01:09:12.049Z: (fe3f48ac4fccd): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-16T01:09:12.102Z: (bd1c343bcb5c5fb5): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Read+PAssert$334/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$334/GroupGlobally/Values/Values/Map+PAssert$334/GroupGlobally/ParDo(Concat)+PAssert$334/GetPane/Map+PAssert$334/RunChecks+PAssert$334/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-16T01:09:14.590Z: (14f0a72e609d7398): Cleaning up.
[INFO] 2017-11-16T01:09:14.625Z: (14f0a72e609d71e2): Stopping worker pool...
[INFO] 2017-11-16T01:09:29.145Z: (134835db3fdb3304): Autoscaling: Resized worker pool from 2 to 0.
[INFO] 2017-11-16T01:09:29.147Z: (134835db3fdb3a62): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-15_17_06_58-18088338909123079072 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_06_58-18088338909123079072. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-16T01:10:21.738Z: (b008ef6cf4a11319): Autoscaling: Resized worker pool from 2 to 0.
[INFO] 2017-11-16T01:10:21.741Z: (b008ef6cf4a1179b): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-16T01:10:21.746Z: (14f0a72e609d7f9a): Worker pool stopped.
[INFO] Job 2017-11-15_17_07_03-308272031525145576 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-15_17_07_03-308272031525145576. Found 3 success, 0 failures out of 3 expected assertions.
2017-11-16T01:10:30.646 [INFO] Running org.apache.beam.sdk.transforms.CombineTest
2017-11-16T01:10:31.161 [INFO] Tests run: 22, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 531.187 s - in org.apache.beam.sdk.transforms.CombineTest
2017-11-16T01:10:31.175 [INFO] Running org.apache.beam.sdk.values.PDoneTest
2017-11-16T01:10:31.182 [WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 s - in org.apache.beam.sdk.values.PDoneTest
2017-11-16T01:10:31.192 [INFO] Running org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest
2017-11-16T01:10:31.200 [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 382.813 s - in org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest
2017-11-16T01:10:31.205 [INFO]
2017-11-16T01:10:31.216 [INFO] Results:
2017-11-16T01:10:31.216 [INFO]
2017-11-16T01:10:31.217 [WARNING] Tests run: 260, Failures: 0, Errors: 0, Skipped: 1
2017-11-16T01:10:31.217 [INFO]
[JENKINS] Recording test results
2017-11-16T01:10:32.512 [INFO]
2017-11-16T01:10:32.512 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only (default) @ beam-runners-google-cloud-dataflow-java ---
2017-11-16T01:10:32.797 [INFO] No dependency problems found
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
[JENKINS] Archiving disabled
2017-11-16T01:10:45.761 [INFO] ------------------------------------------------------------------------
2017-11-16T01:10:45.761 [INFO] Reactor Summary:
2017-11-16T01:10:45.761 [INFO]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 8.275 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 8.944 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Model ............................... SUCCESS [ 1.589 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Model :: Pipeline ................... SUCCESS [ 10.643 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Model :: Job Management ............. SUCCESS [ 7.774 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Model :: Fn Execution ............... SUCCESS [ 8.216 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.315 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 2.245 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [01:30 min]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 2.269 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [ 15.962 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [ 27.435 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [08:33 min]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 2.485 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 2.523 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [ 18.004 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 18.508 s]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [01:29 min]
2017-11-16T01:10:45.761 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:09 h]
2017-11-16T01:10:45.761 [INFO] ------------------------------------------------------------------------
2017-11-16T01:10:45.761 [INFO] BUILD SUCCESS
2017-11-16T01:10:45.761 [INFO] ------------------------------------------------------------------------
2017-11-16T01:10:45.762 [INFO] Total time: 01:24 h
2017-11-16T01:10:45.762 [INFO] Finished at: 2017-11-16T01:10:45+00:00
2017-11-16T01:10:48.165 [INFO] Final Memory: 482M/2471M
2017-11-16T01:10:48.165 [INFO] ------------------------------------------------------------------------
channel stopped
Jenkins build is back to normal :
beam_PostCommit_Java_ValidatesRunner_Dataflow #4354
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4354/display/redirect?page=changes>