See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4082/display/redirect>
------------------------------------------ [...truncated 9.47 MB...] [INFO] 2017-10-02T07:37:37.821Z: (b0c3d0dca8b6b6a3): Executing operation PAssert$321/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$321/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$321/GroupGlobally/GroupDummyAndContents/Reify+PAssert$321/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:37:37.843Z: (177dbb8788d12049): Executing operation PAssert$321/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$321/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$321/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$321/GroupGlobally/RewindowActuals/Window.Assign+PAssert$321/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$321/GroupGlobally/GroupDummyAndContents/Reify+PAssert$321/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:37:40.288Z: (177dbb8788d12daf): Executing operation PAssert$321/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:37:40.318Z: (177dbb8788d124ac): Executing operation PAssert$321/GroupGlobally/GroupDummyAndContents/Read+PAssert$321/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$321/GroupGlobally/Values/Values/Map+PAssert$321/GroupGlobally/ParDo(Concat)+PAssert$321/GetPane/Map+PAssert$321/RunChecks+PAssert$321/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-02T07:37:41.635Z: (3241dc261df528d0): Cleaning up. [INFO] 2017-10-02T07:37:41.640Z: (3241dc261df52dec): Stopping worker pool... [INFO] 2017-10-02T07:37:47.919Z: (6499454305174da2): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-02T07:37:47.921Z: (64994543051743a8): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-02T07:37:47.552Z: (5ab47c4f22e6d945): Executing operation Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/GroupByKey/Close [INFO] 2017-10-02T07:37:47.575Z: (5ab47c4f22e6de6d): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:37:47.636Z: (f5cb9fa341a16dc0): Executing operation Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/GroupByKey/Read+Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/Combine.GroupedValues+Combine.globally(SumInteger)/Values/Values/Map+ParDo(GetLast)+PAssert$325/GroupGlobally/Window.Into()/Window.Assign+PAssert$325/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$325/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$325/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:37:53.731Z: (42f44ef4acc014ff): Executing operation PAssert$324/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:37:53.751Z: (42f44ef4acc01f17): Executing operation PAssert$324/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:37:53.809Z: (42f44ef4acc01853): Executing operation PAssert$324/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$324/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$324/GroupGlobally/GroupDummyAndContents/Reify+PAssert$324/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:37:53.822Z: (69c21ecce3e63d37): Executing operation PAssert$324/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$324/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$324/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$324/GroupGlobally/RewindowActuals/Window.Assign+PAssert$324/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$324/GroupGlobally/GroupDummyAndContents/Reify+PAssert$324/GroupGlobally/GroupDummyAndContents/Write [INFO] Job 2017-10-02_00_34_18-11578191582754064192 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_34_18-11578191582754064192. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-10-02T07:37:55.642Z: (8f51bb091ebfff71): Workers have started successfully. [INFO] 2017-10-02T07:37:57.093Z: (69c21ecce3e63a99): Executing operation PAssert$324/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:37:57.113Z: (69c21ecce3e63278): 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-10-02T07:37:57.189Z: (42667ffc0ebde2c0): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-02T07:37:57.294Z: (42667ffc0ebde26e): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-02T07:37:57.304Z: (4a67e87149d718f2): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-02T07:37:57.410Z: (42667ffc0ebde77f): Executing operation 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-10-02T07:37:57.448Z: (4a67e87149d71481): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write [INFO] 2017-10-02T07:37:58.195Z: (921b715256d275cc): Executing operation PAssert$323/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:37:58.217Z: (921b715256d27c9f): Executing operation PAssert$323/GroupGlobally/GroupDummyAndContents/Read+PAssert$323/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$323/GroupGlobally/Values/Values/Map+PAssert$323/GroupGlobally/ParDo(Concat)+PAssert$323/GetPane/Map+PAssert$323/RunChecks+PAssert$323/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-02T07:38:01.386Z: (a05e9b520907565b): Cleaning up. [INFO] 2017-10-02T07:38:01.391Z: (a05e9b520907559f): Stopping worker pool... [INFO] 2017-10-02T07:38:07.242Z: (3d7c161de6309acf): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-02T07:38:07.272Z: (42667ffc0ebdeb74): Executing operation PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:38:07.347Z: (42667ffc0ebdec67): 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$319/GroupGlobally/Window.Into()/Window.Assign+PAssert$319/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$319/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$319/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:38:08.306Z: (3d7c161de6309e79): Executing operation PAssert$316/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:38:08.338Z: (aecb53c23e1bc70f): Executing operation PAssert$316/GroupGlobally/GroupDummyAndContents/Read+PAssert$316/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$316/GroupGlobally/Values/Values/Map+PAssert$316/GroupGlobally/ParDo(Concat)+PAssert$316/GetPane/Map+PAssert$316/RunChecks+PAssert$316/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-02T07:38:07.337Z: (5ab47c4f22e6d762): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:38:07.358Z: (5ab47c4f22e6dc8a): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:38:07.432Z: (5ab47c4f22e6d16e): 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-10-02T07:38:07.454Z: (f5cb9fa341a16ade): 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-10-02T07:38:09.548Z: (7d056f34a09b7b80): Executing operation Combine.perKey(UniqueInts)/GroupByKey/Close [INFO] 2017-10-02T07:38:09.577Z: (26df2bcfc4d6a248): Executing operation Combine.globally(UniqueInts)/Combine.perKey(UniqueInts)/GroupByKey/Close [INFO] 2017-10-02T07:38:09.607Z: (26df2bcfc4d6a2c0): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:38:09.638Z: (7d056f34a09b7628): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:38:09.720Z: (7d056f34a09b7821): Executing operation Combine.perKey(UniqueInts)/GroupByKey/Read+Combine.perKey(UniqueInts)/Combine.GroupedValues+Combine.perKey(UniqueInts)/Combine.GroupedValues/Extract+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-10-02T07:38:09.750Z: (26df2bcfc4d6a3ec): Executing operation Combine.globally(UniqueInts)/Combine.perKey(UniqueInts)/GroupByKey/Read+Combine.globally(UniqueInts)/Combine.perKey(UniqueInts)/Combine.GroupedValues+Combine.globally(UniqueInts)/Combine.perKey(UniqueInts)/Combine.GroupedValues/Extract+Combine.globally(UniqueInts)/Values/Values/Map+PAssert$326/GroupGlobally/Window.Into()/Window.Assign+PAssert$326/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+Combine.globally(UniqueInts)/View.AsIterable/View.CreatePCollectionView/ParDo(ToIsmRecordForGlobalWindow)+PAssert$326/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$326/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:38:11.266Z: (7d056f34a09b7c1b): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:38:11.298Z: (261243eaeb4da263): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:38:11.381Z: (261243eaeb4da07f): 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-10-02T07:38:11.412Z: (7d056f34a09b76c3): 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-10-02T07:38:12.164Z: (aecb53c23e1bce80): Executing operation PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:38:12.193Z: (aecb53c23e1bc988): Executing operation PAssert$319/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:38:12.272Z: (aecb53c23e1bc8b3): Executing operation PAssert$319/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$319/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$319/GroupGlobally/GroupDummyAndContents/Reify+PAssert$319/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:38:12.303Z: (42667ffc0ebded08): Executing operation PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$319/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$319/GroupGlobally/RewindowActuals/Window.Assign+PAssert$319/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$319/GroupGlobally/GroupDummyAndContents/Reify+PAssert$319/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:38:14.964Z: (5ab47c4f22e6dfcf): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:38:14.999Z: (5ab47c4f22e6d652): 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-10-02T07:38:16.662Z: (26df2bcfc4d6a842): Executing operation Combine.globally(UniqueInts)/View.AsIterable/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-02T07:38:16.709Z: (26df2bcfc4d6a96e): Executing operation Combine.globally(UniqueInts)/CreateVoid/Read(CreateSource)+Combine.globally(UniqueInts)/ProduceDefault+PAssert$326/GroupGlobally/Window.Into()/Window.Assign+PAssert$326/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$326/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$326/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:38:16.547Z: (42667ffc0ebde00a): Executing operation PAssert$319/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:38:16.562Z: (42667ffc0ebde219): Executing operation PAssert$319/GroupGlobally/GroupDummyAndContents/Read+PAssert$319/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$319/GroupGlobally/Values/Values/Map+PAssert$319/GroupGlobally/ParDo(Concat)+PAssert$319/GetPane/Map+PAssert$319/RunChecks+PAssert$319/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-02T07:38:16.920Z: (4a67e87149d71bde): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-02T07:38:16.935Z: (4a67e87149d71b16): Executing operation PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:38:16.979Z: (aecb53c23e1bcaa0): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+PAssert$317/GroupGlobally/Window.Into()/Window.Assign+PAssert$317/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$317/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$317/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:38:17.590Z: (a63a04f87d6b2e9): Cleaning up. [INFO] 2017-10-02T07:38:17.598Z: (a63a04f87d6bc3d): Stopping worker pool... [INFO] 2017-10-02T07:38:19.359Z: (aecb53c23e1bc55f): Executing operation PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:38:19.374Z: (aecb53c23e1bc067): Executing operation PAssert$317/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:38:19.414Z: (aecb53c23e1bcbfb): Executing operation PAssert$317/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$317/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$317/GroupGlobally/GroupDummyAndContents/Reify+PAssert$317/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:38:19.424Z: (4a67e87149d71f09): Executing operation PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$317/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$317/GroupGlobally/RewindowActuals/Window.Assign+PAssert$317/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$317/GroupGlobally/GroupDummyAndContents/Reify+PAssert$317/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:38:19.983Z: (26df2bcfc4d6aaa9): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:38:20.006Z: (26df2bcfc4d6ab21): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:38:20.072Z: (26df2bcfc4d6ac4d): Executing operation PAssert$326/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$326/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$326/GroupGlobally/GroupDummyAndContents/Reify+PAssert$326/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:38:20.091Z: (b6362862f0149224): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$326/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$326/GroupGlobally/RewindowActuals/Window.Assign+PAssert$326/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$326/GroupGlobally/GroupDummyAndContents/Reify+PAssert$326/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:38:20.852Z: (5e8c97e8f31a88b8): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-02T07:38:20.854Z: (5e8c97e8f31a8a72): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-02T07:38:23.436Z: (ec5a6c52030b1070): Workers have started successfully. [INFO] 2017-10-02T07:38:23.859Z: (aecb53c23e1bcde8): Executing operation PAssert$317/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:38:23.874Z: (aecb53c23e1bc78f): Executing operation PAssert$317/GroupGlobally/GroupDummyAndContents/Read+PAssert$317/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$317/GroupGlobally/Values/Values/Map+PAssert$317/GroupGlobally/ParDo(Concat)+PAssert$317/GetPane/Map+PAssert$317/RunChecks+PAssert$317/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-02T07:38:24.250Z: (50c47a06f6f95e5b): Cleaning up. [INFO] 2017-10-02T07:38:24.255Z: (50c47a06f6f9539f): Stopping worker pool... [INFO] 2017-10-02T07:38:27.371Z: (261243eaeb4dacde): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:38:27.386Z: (261243eaeb4dae9b): 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] Job 2017-10-02_00_34_45-15198338025830973024 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_34_45-15198338025830973024. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-10-02T07:38:28.714Z: (b6362862f0149922): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:38:28.729Z: (b6362862f0149213): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Read+PAssert$326/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$326/GroupGlobally/Values/Values/Map+PAssert$326/GroupGlobally/ParDo(Concat)+PAssert$326/GetPane/Map+PAssert$326/RunChecks+PAssert$326/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-02T07:38:32.025Z: (dcc9ee8aeecefdd3): Executing operation Combine.perKey(MeanInts)/GroupByKey/Close [INFO] 2017-10-02T07:38:32.046Z: (7e80228847f79e0c): Executing operation Combine.globally(MeanInts)/Combine.perKey(MeanInts)/GroupByKey/Close [INFO] 2017-10-02T07:38:32.061Z: (dcc9ee8aeecef7ab): Executing operation PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:38:32.085Z: (7e80228847f79bf4): Executing operation PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:38:32.148Z: (7e80228847f79513): Executing operation Combine.perKey(MeanInts)/GroupByKey/Read+Combine.perKey(MeanInts)/Combine.GroupedValues+Combine.perKey(MeanInts)/Combine.GroupedValues/Extract+PAssert$329/GroupGlobally/Window.Into()/Window.Assign+PAssert$329/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$329/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$329/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:38:32.172Z: (dcc9ee8aeecef895): 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$328/GroupGlobally/Window.Into()/Window.Assign+PAssert$328/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+Combine.globally(MeanInts)/View.AsIterable/View.CreatePCollectionView/ParDo(ToIsmRecordForGlobalWindow)+PAssert$328/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$328/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:38:34.898Z: (7d169ae52fc7cf1d): Cleaning up. [INFO] 2017-10-02T07:38:34.903Z: (7d169ae52fc7c369): Stopping worker pool... [INFO] 2017-10-02T07:38:34.696Z: (7e80228847f7985d): Executing operation PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:38:34.718Z: (d73a1fef3bbea971): Executing operation PAssert$329/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:38:34.790Z: (7e80228847f79645): 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-10-02T07:38:34.812Z: (d73a1fef3bbeacad): 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-10-02T07:38:36.721Z: (3debdf9d9a8d97f2): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-02T07:38:36.723Z: (3debdf9d9a8d9330): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-02T07:38:40.128Z: (d73a1fef3bbeac63): Executing operation PAssert$329/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:38:40.149Z: (d73a1fef3bbea8b8): 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] Job 2017-10-02_00_34_53-4376089184375140270 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_34_53-4376089184375140270. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-10-02T07:38:47.041Z: (dcc9ee8aeecef7a3): Executing operation Combine.globally(MeanInts)/View.AsIterable/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-02T07:38:47.107Z: (dcc9ee8aeecef83f): Executing operation Combine.globally(MeanInts)/CreateVoid/Read(CreateSource)+Combine.globally(MeanInts)/ProduceDefault+PAssert$328/GroupGlobally/Window.Into()/Window.Assign+PAssert$328/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$328/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$328/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:38:48.800Z: (1e47fd947a6fdc67): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-02T07:38:48.802Z: (1e47fd947a6fd899): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-02T07:38:52.079Z: (d7d2cbc0bc50ed66): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Close [INFO] 2017-10-02T07:38:52.106Z: (d7d2cbc0bc50ebbf): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-10-02T07:38:52.117Z: (388818e4ddf142d7): Executing operation PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:38:52.183Z: (388818e4ddf1494c): 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/View.CreatePCollectionView/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$330/GroupGlobally/Window.Into()/Window.Assign+PAssert$330/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$330/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$330/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:38:51.654Z: (dcc9ee8aeecefc16): Executing operation PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:38:51.670Z: (dcc9ee8aeecef5ee): Executing operation PAssert$328/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:38:51.714Z: (dcc9ee8aeecef68a): Executing operation PAssert$328/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$328/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$328/GroupGlobally/GroupDummyAndContents/Reify+PAssert$328/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:38:51.725Z: (7e80228847f79109): Executing operation PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$328/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$328/GroupGlobally/RewindowActuals/Window.Assign+PAssert$328/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$328/GroupGlobally/GroupDummyAndContents/Reify+PAssert$328/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:38:55.150Z: (388818e4ddf149ba): Executing operation Sum/View.AsIterable/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-02T07:38:55.219Z: (388818e4ddf14b4e): 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$330/GroupGlobally/Window.Into()/Window.Assign+PAssert$330/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$330/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$330/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-02T07:38:57.137Z: (7e80228847f79453): Executing operation PAssert$328/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:38:57.155Z: (7e80228847f79e7e): Executing operation PAssert$328/GroupGlobally/GroupDummyAndContents/Read+PAssert$328/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$328/GroupGlobally/Values/Values/Map+PAssert$328/GroupGlobally/ParDo(Concat)+PAssert$328/GetPane/Map+PAssert$328/RunChecks+PAssert$328/VerifyAssertions/ParDo(DefaultConclude) [INFO] Job 2017-10-02_00_35_11-7058577582823024571 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_35_11-7058577582823024571. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-10-02T07:38:58.102Z: (8d958ccdc7c8b544): Autoscaling: Resizing worker pool from 1 to 2. [INFO] 2017-10-02T07:38:59.862Z: (388818e4ddf14b85): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-02T07:38:59.873Z: (d7d2cbc0bc50e6f9): Executing operation PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:38:59.883Z: (388818e4ddf1428d): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-02T07:38:59.893Z: (d7d2cbc0bc50e581): Executing operation PAssert$330/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:38:59.926Z: (d7d2cbc0bc50e37c): 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/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-10-02T07:38:59.951Z: (388818e4ddf14b29): Executing operation PAssert$330/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$330/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$330/GroupGlobally/GroupDummyAndContents/Reify+PAssert$330/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:39:00.227Z: (2d708b52f96a9191): Executing operation PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$330/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$330/GroupGlobally/RewindowActuals/Window.Assign+PAssert$330/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$330/GroupGlobally/GroupDummyAndContents/Reify+PAssert$330/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-02T07:38:59.529Z: (78a6f90cd7fc1188): Cleaning up. [INFO] 2017-10-02T07:38:59.533Z: (78a6f90cd7fc1d5c): Stopping worker pool... [INFO] 2017-10-02T07:39:03.650Z: (8f5b137499874dba): Autoscaling: Raised the number of workers to 2 based on the rate of progress in the currently running step(s). [INFO] 2017-10-02T07:39:08.210Z: (c24ae6143db75397): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-02T07:39:08.212Z: (c24ae6143db75b71): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-02T07:39:07.798Z: (b1b07f81c9c17ce): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-02T07:39:07.801Z: (b1b07f81c9c1b70): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-02T07:39:11.884Z: (388818e4ddf14a96): Executing operation PAssert$330/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:39:11.905Z: (388818e4ddf14cbd): Executing operation PAssert$330/GroupGlobally/GroupDummyAndContents/Read+PAssert$330/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$330/GroupGlobally/Values/Values/Map+PAssert$330/GroupGlobally/ParDo(Concat)+PAssert$330/GetPane/Map+PAssert$330/RunChecks+PAssert$330/VerifyAssertions/ParDo(DefaultConclude) [INFO] Job 2017-10-02_00_35_34-14962247823193887499 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_35_34-14962247823193887499. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-10-02_00_34_53-10255496890346712050 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_34_53-10255496890346712050. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-10-02T07:39:19.459Z: (d7d2cbc0bc50e02e): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-02T07:39:19.474Z: (d7d2cbc0bc50eee5): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-10-02T07:39:26.534Z: (7173284aa4016831): Autoscaling: Resized worker pool from 2 to 0. [INFO] 2017-10-02T07:39:26.536Z: (7173284aa4016683): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-02T07:39:27.652Z: (d7d2cbc0bc50e72f): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-02T07:39:27.752Z: (388818e4ddf14813): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-02T07:39:27.778Z: (d7d2cbc0bc50e1ad): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-02T07:39:27.926Z: (d7d2cbc0bc50ee5f): 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-10-02T07:39:27.955Z: (2d708b52f96a95d8): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write [INFO] 2017-10-02T07:39:28.485Z: (d7d2cbc0bc50e8dd): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-02T07:39:28.569Z: (d7d2cbc0bc50e765): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:39:28.782Z: (d7d2cbc0bc50e3b9): 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$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-10-02T07:39:28.829Z: (2d708b52f96a95da): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-02T07:39:28.863Z: (2d708b52f96a9d52): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-02T07:39:28.935Z: (d5f4ceb7c7cb494): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+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-10-02T07:39:30.064Z: (d7d2cbc0bc50edaa): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:39:30.097Z: (2d708b52f96a97fe): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:39:30.175Z: (2d708b52f96a92aa): 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-10-02T07:39:30.201Z: (d7d2cbc0bc50ec32): 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-10-02T07:39:34.366Z: (d5f4ceb7c7cbf1d): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-02T07:39:34.409Z: (d5f4ceb7c7cb1d5): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-02T07:39:34.501Z: (d5f4ceb7c7cb592): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:39:34.517Z: (2d708b52f96a9b34): 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-10-02T07:39:34.531Z: (d5f4ceb7c7cb7f3): 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] 2017-10-02T07:39:34.548Z: (d7d2cbc0bc50e8e4): 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] Job 2017-10-02_00_36_26-2818212057438862040 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_36_26-2818212057438862040. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-10-02T07:39:37.736Z: (d5f4ceb7c7cbe11): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-02T07:39:37.760Z: (d5f4ceb7c7cb072): 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] 2017-10-02T07:39:44.351Z: (98978754d39d1fd9): Cleaning up. [INFO] 2017-10-02T07:39:44.360Z: (98978754d39d10dd): Stopping worker pool... [INFO] 2017-10-02T07:39:54.998Z: (a99a8511602cb4dc): Autoscaling: Resized worker pool from 2 to 0. [INFO] 2017-10-02T07:39:55.000Z: (a99a8511602cb2ea): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-10-02_00_36_39-1326767969099530048 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_36_39-1326767969099530048. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-10-02T07:40:06.247Z: (1345998bda4fc859): Cleaning up. [INFO] 2017-10-02T07:40:06.253Z: (1345998bda4fcdf5): Stopping worker pool... [INFO] 2017-10-02T07:40:36.314Z: (8f5b137499874920): Autoscaling: Resized worker pool from 2 to 0. [INFO] 2017-10-02T07:40:36.318Z: (8f5b137499874c4a): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-10-02_00_36_40-10750129126359985449 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_36_40-10750129126359985449. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-10-02T07:41:06.367Z: (fb2f58d31b0bd730): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-02T07:41:06.369Z: (fb2f58d31b0bd99e): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-10-02_00_34_32-16292028349743092597 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-02_00_34_32-16292028349743092597. Found 2 success, 0 failures out of 2 expected assertions. 2017-10-02T07:41:17.015 [INFO] Running [limit_36] 2017-10-02T07:41:17.289 [INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1,528.779 s - in [limit_36] 2017-10-02T07:41:17.289 [INFO] Running org.apache.beam.sdk.transforms.CombineTest 2017-10-02T07:41:17.498 [INFO] Tests run: 22, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 570.268 s - in org.apache.beam.sdk.transforms.CombineTest 2017-10-02T07:41:17.502 [INFO] Running org.apache.beam.sdk.values.PDoneTest 2017-10-02T07:41:17.509 [WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 s - in org.apache.beam.sdk.values.PDoneTest 2017-10-02T07:41:17.526 [INFO] 2017-10-02T07:41:17.526 [INFO] Results: 2017-10-02T07:41:17.526 [INFO] 2017-10-02T07:41:17.526 [WARNING] Tests run: 264, Failures: 0, Errors: 0, Skipped: 1 2017-10-02T07:41:17.526 [INFO] [JENKINS] Recording test results 2017-10-02T07:41:19.295 [INFO] 2017-10-02T07:41:19.295 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-10-02T07:41:19.582 [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 2017-10-02T07:41:36.819 [INFO] ------------------------------------------------------------------------ 2017-10-02T07:41:36.819 [INFO] Reactor Summary: 2017-10-02T07:41:36.819 [INFO] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 25.101 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 13.647 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.853 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Common ...................... SUCCESS [ 2.338 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Common :: Runner API ........ SUCCESS [ 23.914 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Common :: Fn API ............ SUCCESS [ 12.075 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 2.368 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [02:15 min] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 2.339 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [ 18.166 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [ 33.799 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [07:20 min] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 3.043 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 2.907 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [ 22.175 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 23.822 s] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [01:39 min] 2017-10-02T07:41:36.820 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:24 h] 2017-10-02T07:41:36.820 [INFO] ------------------------------------------------------------------------ 2017-10-02T07:41:36.820 [INFO] BUILD SUCCESS 2017-10-02T07:41:36.820 [INFO] ------------------------------------------------------------------------ 2017-10-02T07:41:36.820 [INFO] Total time: 01:40 h 2017-10-02T07:41:36.820 [INFO] Finished at: 2017-10-02T07:41:36+00:00 [JENKINS] Archiving disabled 2017-10-02T07:41:39.070 [INFO] Final Memory: 324M/2293M 2017-10-02T07:41:39.070 [INFO] ------------------------------------------------------------------------ channel stopped
