See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4130/display/redirect?page=changes>
Changes: [klk] Fix typo in nightly release script [kirpichov] Fixes TextIO and AvroIO tests of watchForNewFiles [kirpichov] Add @FunctionalInterface annotation to several interfaces ------------------------------------------ [...truncated 21.06 MB...] [INFO] 2017-10-09T21:46:36.557Z: (81796e4cf2df7253): Fusing unzipped copy of PAssert$327/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$327/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-10-09T21:46:36.560Z: (81796e4cf2df7589): Fusing consumer PAssert$327/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$327/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-10-09T21:46:36.562Z: (81796e4cf2df78bf): Unzipping flatten s37-u117 for input s39-reify-value59-c115 [INFO] 2017-10-09T21:46:36.564Z: (81796e4cf2df7bf5): Fusing unzipped copy of PAssert$325/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$325/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.566Z: (81796e4cf2df7f2b): Unzipping flatten s77-u122 for input s79-reify-value104-c120 [INFO] 2017-10-09T21:46:36.569Z: (81796e4cf2df7261): Fusing unzipped copy of PAssert$327/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$327/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.571Z: (81796e4cf2df7597): Unzipping flatten s57 for input s52.52 [INFO] 2017-10-09T21:46:36.574Z: (81796e4cf2df78cd): Fusing unzipped copy of PAssert$326/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$326/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-10-09T21:46:36.576Z: (81796e4cf2df7c03): Fusing consumer PAssert$326/GetPane/Map into PAssert$326/GroupGlobally/ParDo(Concat) [INFO] 2017-10-09T21:46:36.579Z: (81796e4cf2df7f39): Fusing consumer PAssert$326/RunChecks into PAssert$326/GetPane/Map [INFO] 2017-10-09T21:46:36.582Z: (81796e4cf2df726f): Unzipping flatten s57-u131 for input s59-reify-value77-c129 [INFO] 2017-10-09T21:46:36.585Z: (81796e4cf2df75a5): Fusing unzipped copy of PAssert$326/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$326/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.587Z: (81796e4cf2df78db): Fusing consumer PAssert$326/VerifyAssertions/ParDo(DefaultConclude) into PAssert$326/RunChecks [INFO] 2017-10-09T21:46:36.590Z: (81796e4cf2df7c11): Fusing consumer PAssert$326/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$326/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-10-09T21:46:36.593Z: (81796e4cf2df7f47): Fusing consumer PAssert$326/GroupGlobally/Values/Values/Map into PAssert$326/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-10-09T21:46:36.596Z: (81796e4cf2df727d): Fusing consumer PAssert$326/GroupGlobally/ParDo(Concat) into PAssert$326/GroupGlobally/Values/Values/Map [INFO] 2017-10-09T21:46:36.598Z: (81796e4cf2df75b3): Fusing consumer Sum/Combine.perKey(SumInts)/GroupByKey/Write into Sum/Combine.perKey(SumInts)/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.600Z: (81796e4cf2df78e9): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read [INFO] 2017-10-09T21:46:36.604Z: (81796e4cf2df7c1f): Fusing consumer Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues into Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.606Z: (81796e4cf2df7f55): Fusing consumer PAssert$326/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$326/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-10-09T21:46:36.609Z: (81796e4cf2df728b): Fusing consumer PAssert$326/GroupGlobally/RewindowActuals/Window.Assign into PAssert$326/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-10-09T21:46:36.611Z: (81796e4cf2df75c1): Fusing consumer PAssert$327/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.614Z: (81796e4cf2df78f7): Fusing consumer PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-10-09T21:46:36.616Z: (81796e4cf2df7c2d): Fusing consumer PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.618Z: (81796e4cf2df7f63): Fusing consumer PAssert$327/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$327/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-10-09T21:46:36.621Z: (81796e4cf2df7299): Fusing consumer PAssert$327/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$327/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.623Z: (81796e4cf2df75cf): Fusing consumer Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow into Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read [INFO] 2017-10-09T21:46:36.625Z: (81796e4cf2df7905): Fusing consumer PAssert$326/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.627Z: (81796e4cf2df7c3b): Fusing consumer PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-10-09T21:46:36.630Z: (81796e4cf2df7f71): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map [INFO] 2017-10-09T21:46:36.632Z: (81796e4cf2df72a7): Fusing consumer PAssert$325/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$325/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.635Z: (81796e4cf2df75dd): 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-10-09T21:46:36.637Z: (81796e4cf2df7913): Fusing consumer PAssert$325/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$325/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.639Z: (81796e4cf2df7c49): Fusing consumer PAssert$327/GroupGlobally/Window.Into()/Window.Assign into Combine.globally(TestCombineFnWithContext)/Values/Values/Map [INFO] 2017-10-09T21:46:36.642Z: (81796e4cf2df7f7f): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.645Z: (81796e4cf2df72b5): Fusing consumer Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write into Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.647Z: (81796e4cf2df75eb): Fusing consumer PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.650Z: (81796e4cf2df7921): Fusing consumer PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$326/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.653Z: (81796e4cf2df7c57): Fusing consumer Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify into Combine.globally(TestCombineFnWithContext)/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.655Z: (81796e4cf2df7f8d): Fusing consumer PAssert$326/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$326/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.657Z: (81796e4cf2df72c3): Fusing consumer PAssert$326/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$326/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-10-09T21:46:36.660Z: (81796e4cf2df75f9): Fusing consumer Combine.globally(TestCombineFnWithContext)/WithKeys/AddKeys/Map into Globally Input Sessions/Window.Assign [INFO] 2017-10-09T21:46:36.662Z: (81796e4cf2df792f): Fusing consumer PAssert$326/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$326/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.664Z: (81796e4cf2df7c65): Fusing consumer Sum/Combine.perKey(SumInts)/GroupByKey+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Partial into Sum/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.667Z: (81796e4cf2df7f9b): Fusing consumer Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify into PerKey Input Sessions/Window.Assign [INFO] 2017-10-09T21:46:36.671Z: (81796e4cf2df72d1): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial [INFO] 2017-10-09T21:46:36.676Z: (81796e4cf2df7607): Fusing consumer PAssert$326/GroupGlobally/Window.Into()/Window.Assign into Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues [INFO] 2017-10-09T21:46:36.679Z: (81796e4cf2df793d): Fusing consumer Create.TimestampedValues/ParDo(ConvertTimestamps) into Create.TimestampedValues/Create.Values/Read(CreateSource) [INFO] 2017-10-09T21:46:36.682Z: (81796e4cf2df7c73): Fusing consumer Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write into Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.685Z: (81796e4cf2df7fa9): Fusing consumer Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues into Combine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.688Z: (81796e4cf2df72df): Fusing consumer Sum/Combine.perKey(SumInts)/GroupByKey/Reify into Sum/Combine.perKey(SumInts)/GroupByKey+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Partial [INFO] 2017-10-09T21:46:36.692Z: (81796e4cf2df7615): Fusing consumer Combine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow into Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read [INFO] 2017-10-09T21:46:36.695Z: (81796e4cf2df794b): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.697Z: (81796e4cf2df7c81): Fusing consumer PAssert$327/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$327/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-10-09T21:46:36.700Z: (81796e4cf2df7fb7): Fusing consumer PAssert$327/GroupGlobally/RewindowActuals/Window.Assign into PAssert$327/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-10-09T21:46:36.703Z: (81796e4cf2df72ed): Fusing consumer PAssert$325/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$325/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-10-09T21:46:36.705Z: (81796e4cf2df7623): Fusing consumer PAssert$325/GroupGlobally/RewindowActuals/Window.Assign into PAssert$325/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-10-09T21:46:36.707Z: (81796e4cf2df7959): Fusing consumer PAssert$325/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.710Z: (81796e4cf2df7c8f): Fusing consumer PAssert$327/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$327/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.713Z: (81796e4cf2df7fc5): Fusing consumer PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.716Z: (81796e4cf2df72fb): Fusing consumer Sum/Values/Values/Map into Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract [INFO] 2017-10-09T21:46:36.719Z: (81796e4cf2df7631): Fusing consumer Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract into Sum/Combine.perKey(SumInts)/Combine.GroupedValues [INFO] 2017-10-09T21:46:36.722Z: (81796e4cf2df7967): Fusing consumer Sum/WithKeys/AddKeys/Map into FixedWindows/Window.Assign [INFO] 2017-10-09T21:46:36.725Z: (81796e4cf2df7c9d): 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-10-09T21:46:36.727Z: (81796e4cf2df7fd3): Fusing consumer Combine.globally(TestCombineFnWithContext)/Values/Values/Map into Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues [INFO] 2017-10-09T21:46:36.730Z: (81796e4cf2df7309): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) into View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read [INFO] 2017-10-09T21:46:36.732Z: (81796e4cf2df763f): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) [INFO] 2017-10-09T21:46:36.735Z: (81796e4cf2df7975): Fusing consumer PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-10-09T21:46:36.738Z: (81796e4cf2df7cab): Fusing consumer PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$327/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.740Z: (81796e4cf2df7fe1): Fusing consumer PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$325/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.743Z: (81796e4cf2df7317): Fusing consumer PAssert$325/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$325/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-10-09T21:46:36.745Z: (81796e4cf2df764d): Fusing consumer Sum/Combine.perKey(SumInts)/Combine.GroupedValues into Sum/Combine.perKey(SumInts)/GroupByKey/Read [INFO] 2017-10-09T21:46:36.748Z: (81796e4cf2df7983): Fusing consumer PAssert$326/GroupGlobally/GroupDummyAndContents/Reify into PAssert$326/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-10-09T21:46:36.749Z: (81796e4cf2df7cb9): Fusing consumer PAssert$325/GroupGlobally/GroupDummyAndContents/Reify into PAssert$325/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-10-09T21:46:36.752Z: (81796e4cf2df7fef): Fusing consumer PAssert$327/GroupGlobally/GroupDummyAndContents/Reify into PAssert$327/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-10-09T21:46:36.754Z: (81796e4cf2df7325): Fusing consumer PAssert$327/GroupGlobally/GroupDummyAndContents/Write into PAssert$327/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.757Z: (81796e4cf2df765b): Fusing consumer PAssert$325/GroupGlobally/GroupDummyAndContents/Write into PAssert$325/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.759Z: (81796e4cf2df7991): Fusing consumer PAssert$326/GroupGlobally/GroupDummyAndContents/Write into PAssert$326/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.762Z: (81796e4cf2df7cc7): Fusing consumer PAssert$325/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$325/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-10-09T21:46:36.764Z: (81796e4cf2df7ffd): Fusing consumer PAssert$326/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$326/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-10-09T21:46:36.767Z: (81796e4cf2df7333): Fusing consumer PAssert$327/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$327/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-10-09T21:46:36.781Z: (81796e4cf2df799f): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-10-09T21:46:36.954Z: (84505a5cee2dd465): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-09T21:46:36.966Z: (2e689d88c7371bec): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-09T21:46:36.971Z: (4d277a79dc32c4a6): Starting 1 workers in us-central1-f... [INFO] 2017-10-09T21:46:36.978Z: (3818e533f1a99a1a): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Create [INFO] 2017-10-09T21:46:37.071Z: (84505a5cee2dd986): Executing operation Create.TimestampedValues/Create.Values/Read(CreateSource)+Create.TimestampedValues/ParDo(ConvertTimestamps)+PerKey Input Sessions/Window.Assign+Values/Values/Map+Globally Input Sessions/Window.Assign+FixedWindows/Window.Assign+Combine.globally(TestCombineFnWithContext)/WithKeys/AddKeys/Map+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write+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-10-09T21:46:44.833Z: (e02afb87ad972c9e): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] 2017-10-09T21:46:55.329Z: (e02afb87ad972695): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2017-10-09T21:46:56.247Z: (4f0b830678ff0541): Executing operation PAssert$324/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:46:56.266Z: (4f0b830678ff04e0): 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-09T21:46:57.641Z: (ef64e663c99fb245): Cleaning up. [INFO] 2017-10-09T21:46:57.646Z: (ef64e663c99fb2c9): Stopping worker pool... [INFO] 2017-10-09T21:46:57.973Z: (634674dfa98c917): Executing operation PAssert$321/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:46:57.997Z: (a13b96a8dda9a175): Executing operation PAssert$321/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:46:58.064Z: (634674dfa98c14a): 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-09T21:46:58.082Z: (a13b96a8dda9a2e6): 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-09T21:47:00.068Z: (e5d5f23c5aff5ede): Executing operation PAssert$329/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:00.092Z: (21585be0fbe34dce): 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-10-09T21:47:01.869Z: (47cb176c41fcd4ba): Executing operation Combine.globally(MeanInts)/View.AsIterable/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-09T21:47:02.309Z: (634674dfa98c174): Executing operation PAssert$321/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:02.342Z: (634674dfa98c989): 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-09T21:47:02.386Z: (a13b96a8dda9adfc): Executing operation PAssert$323/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:02.413Z: (c20176ac76c22739): Executing operation PAssert$323/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:02.468Z: (c20176ac76c2270e): Executing operation PAssert$323/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$323/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$323/GroupGlobally/GroupDummyAndContents/Reify+PAssert$323/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:47:02.481Z: (a13b96a8dda9a31f): Executing operation PAssert$323/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$323/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$323/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$323/GroupGlobally/RewindowActuals/Window.Assign+PAssert$323/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$323/GroupGlobally/GroupDummyAndContents/Reify+PAssert$323/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:47:02.687Z: (48865561c4748d8d): Executing operation Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PreCombineHot/GroupByKey/Close [INFO] 2017-10-09T21:47:02.721Z: (48865561c4748a3c): Executing operation Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PreCombineHot/GroupByKey/Read+Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PreCombineHot/Combine.GroupedValues+Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/StripNonce/Map+Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/Window.Remerge/Identity/Map+Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/GroupByKey/Reify+Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/GroupByKey/Write [INFO] 2017-10-09T21:47:01.969Z: (2549a414b4e9da01): 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-10-09T21:47:02.000Z: (f71bdd3335f996a5): Cleaning up. [INFO] 2017-10-09T21:47:02.005Z: (f71bdd3335f991b9): Stopping worker pool... [INFO] 2017-10-09T21:47:04.706Z: (5d69db5610a8e004): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Close [INFO] 2017-10-09T21:47:04.728Z: (eeeef747b58601ef): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-10-09T21:47:04.748Z: (5d69db5610a8e227): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:04.805Z: (eeeef747b5860926): 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$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-10-09T21:47:05.859Z: (2549a414b4e9df0a): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:05.877Z: (2549a414b4e9d032): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:05.963Z: (2549a414b4e9db16): 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-09T21:47:05.974Z: (47cb176c41fcd019): 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-09T21:47:09.075Z: (a13b96a8dda9ae35): Executing operation PAssert$323/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:09.091Z: (a13b96a8dda9a7da): 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-09T21:47:07.916Z: (ea20ccea2e0f3fd8): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-09T21:47:07.919Z: (ea20ccea2e0f3092): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-09T21:47:09.128Z: (48865561c47483fe): Executing operation Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/GroupByKey/Close [INFO] 2017-10-09T21:47:09.146Z: (48865561c47484c6): Executing operation PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:09.202Z: (48865561c47486ba): 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$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-09T21:47:08.841Z: (eeeef747b5860904): Executing operation Sum/View.AsIterable/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-09T21:47:08.893Z: (eeeef747b5860f38): 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-10-09T21:47:10.794Z: (a8f3e6d9524cfff3): Autoscaling: Resizing worker pool from 1 to 2. [INFO] 2017-10-09T21:47:12.447Z: (77c7163ced5b58b3): Cleaning up. [INFO] 2017-10-09T21:47:12.451Z: (77c7163ced5b530f): Stopping worker pool... [INFO] 2017-10-09T21:47:12.980Z: (5d69db5610a8eed7): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-09T21:47:12.999Z: (eeeef747b5860727): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:13.012Z: (5d69db5610a8ed2f): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-09T21:47:13.035Z: (eeeef747b586066f): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:13.094Z: (eeeef747b5860772): 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-09T21:47:13.111Z: (ce96e8e67d875b18): 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-10-09T21:47:13.128Z: (5d69db5610a8e540): 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-10-09T21:47:15.015Z: (48865561c474807c): Executing operation PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:15.563Z: (2549a414b4e9d91c): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:15.587Z: (2549a414b4e9d01f): 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-10-09T21:47:15.041Z: (940ffcf7d505338): Executing operation PAssert$328/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:15.097Z: (48865561c4748625): 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-09T21:47:15.118Z: (940ffcf7d505877): 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-09T21:47:16.352Z: (3f45a207cd9898fd): Autoscaling: Raised the number of workers to 2 based on the rate of progress in the currently running step(s). [INFO] Job 2017-10-09_14_43_47-12406762828826977461 finished with status DONE. [INFO] 2017-10-09T21:47:17.439Z: (ff92d284ad653b35): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:17.457Z: (ff92d284ad6536ba): 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] Success result for Dataflow job 2017-10-09_14_43_47-12406762828826977461. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-10-09T21:47:20.459Z: (58871228fed4a8c1): Cleaning up. [INFO] 2017-10-09T21:47:20.464Z: (58871228fed4a0d5): Stopping worker pool... [INFO] 2017-10-09T21:47:22.683Z: (ce96e8e67d875ab7): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:22.698Z: (ce96e8e67d875e34): 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-10-09T21:47:22.751Z: (48865561c4748b6a): Executing operation PAssert$328/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:22.772Z: (48865561c4748819): 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] 2017-10-09T21:47:25.719Z: (615f6dfabba40fa8): Cleaning up. [INFO] 2017-10-09T21:47:25.723Z: (615f6dfabba406c4): Stopping worker pool... [INFO] 2017-10-09T21:47:24.595Z: (4b113dd5d919ea7a): Workers have started successfully. [INFO] 2017-10-09T21:47:24.849Z: (766f386d3f893e3a): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-09T21:47:24.851Z: (766f386d3f893280): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-09T21:47:24.856Z: (36218e23a8d7cec3): Worker pool stopped. [INFO] 2017-10-09T21:47:32.528Z: (eeeef747b58601d4): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-09T21:47:32.544Z: (eeeef747b5860b33): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] Job 2017-10-09_14_44_04-15577214043146081346 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-09_14_44_04-15577214043146081346. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-10-09T21:47:41.594Z: (eeeef747b586036d): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-09T21:47:41.685Z: (eeeef747b58604bb): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-09T21:47:41.694Z: (ce96e8e67d875006): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-09T21:47:41.780Z: (ce96e8e67d87569f): 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-09T21:47:41.801Z: (eeeef747b586044e): 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-09T21:47:43.819Z: (ce96e8e67d875bee): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-09T21:47:43.842Z: (ce96e8e67d8756c6): Executing operation PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:43.891Z: (ce96e8e67d8759e2): 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-10-09T21:47:44.944Z: (ce96e8e67d875542): Executing operation PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:44.963Z: (ce96e8e67d87501a): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:45.005Z: (ce96e8e67d875336): 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-10-09T21:47:45.016Z: (8c98cac1cc419c83): 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-10-09T21:47:46.662Z: (eeeef747b586059c): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-09T21:47:46.676Z: (eeeef747b58604e4): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:46.726Z: (eeeef747b5860b18): 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-10-09T21:47:47.823Z: (eeeef747b5860838): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:47.876Z: (eeeef747b5860780): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:47.926Z: (eeeef747b5860db4): 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-10-09T21:47:47.940Z: (5d69db5610a8ec7d): 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-10-09T21:47:49.317Z: (d13272e217de526e): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-09T21:47:49.319Z: (d13272e217de57a0): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-09T21:47:50.350Z: (84505a5cee2dd8ab): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Close [INFO] 2017-10-09T21:47:50.369Z: (44a651d701e683ef): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-09T21:47:50.383Z: (84505a5cee2dd928): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-09T21:47:50.401Z: (2e689d88c7371e42): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-10-09T21:47:50.419Z: (84505a5cee2dd7d0): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:50.485Z: (84505a5cee2ddc74): 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+PAssert$325/GroupGlobally/Window.Into()/Window.Assign+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+PAssert$325/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+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$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-09T21:47:50.079Z: (5d69db5610a8e0c3): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:50.094Z: (5d69db5610a8eb50): 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-10-09T21:47:52.393Z: (ce96e8e67d8752d5): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:52.412Z: (ce96e8e67d875652): 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] Job 2017-10-09_14_44_23-9008148160174578587 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-09_14_44_23-9008148160174578587. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-10-09T21:47:55.945Z: (35854c58b1bc8230): Cleaning up. [INFO] 2017-10-09T21:47:55.950Z: (35854c58b1bc8284): Stopping worker pool... [INFO] 2017-10-09T21:47:59.891Z: (4b7a43066729de46): Autoscaling: Resized worker pool from 2 to 0. [INFO] 2017-10-09T21:47:59.893Z: (4b7a43066729dd84): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-09T21:47:59.400Z: (84505a5cee2dd118): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-09T21:47:59.410Z: (2e689d88c7371d3b): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:59.421Z: (84505a5cee2ddfc0): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-09T21:47:59.432Z: (2e689d88c73718b3): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:59.465Z: (84505a5cee2dd28f): 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-09T21:47:59.490Z: (2e689d88c7371d5f): 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-09T21:47:59.504Z: (44a651d701e68227): 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-09T21:48:02.157Z: (a5ab100c94b3247b): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-09T21:48:02.159Z: (a5ab100c94b320f9): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-10-09_14_45_27-2042731979221376495 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-09_14_45_27-2042731979221376495. Found 2 success, 0 failures out of 2 expected assertions. [INFO] Job 2017-10-09_14_44_12-18150867826303806192 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-09_14_44_12-18150867826303806192. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-10-09T21:48:11.440Z: (84505a5cee2dd389): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-09T21:48:11.460Z: (84505a5cee2dd05c): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-10-09T21:48:12.533Z: (44a651d701e68625): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:48:12.555Z: (44a651d701e68896): 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-09T21:48:23.696Z: (84505a5cee2dd59c): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-09T21:48:23.786Z: (44a651d701e689e8): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:48:23.816Z: (84505a5cee2dddea): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:48:23.904Z: (44a651d701e68574): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+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-10-09T21:48:23.936Z: (2e689d88c7371fc7): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+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-09T21:48:27.237Z: (84505a5cee2dd211): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:48:27.283Z: (84505a5cee2dd0b9): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:48:27.364Z: (84505a5cee2dd4e0): 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-09T21:48:27.394Z: (44a651d701e685e2): 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-09T21:48:31.629Z: (2e689d88c737159e): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:48:31.660Z: (3818e533f1a993e7): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:48:31.733Z: (3818e533f1a99ba3): 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-09T21:48:31.764Z: (44a651d701e689e0): 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-09T21:48:31.588Z: (9eee20d5e7f1796e): Autoscaling: Resized worker pool from 2 to 0. [INFO] 2017-10-09T21:48:31.590Z: (9eee20d5e7f170f8): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-09T21:48:31.204Z: (3a1d4882e78aee0f): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-09T21:48:31.205Z: (3a1d4882e78ae679): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-09T21:48:31.794Z: (84505a5cee2ddcb1): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:48:31.838Z: (84505a5cee2dd984): 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-10-09T21:48:36.481Z: (44a651d701e68dde): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:48:36.528Z: (44a651d701e6804f): 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-09T21:48:37.998Z: (81796e4cf2df7019): Cleaning up. [INFO] 2017-10-09T21:48:38.005Z: (81796e4cf2df7685): Stopping worker pool... [INFO] Job 2017-10-09_14_45_24-13725055260415002817 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-09_14_45_24-13725055260415002817. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-10-09_14_45_31-11972494551378497726 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-09_14_45_31-11972494551378497726. Found 2 success, 0 failures out of 2 expected assertions. ERROR: Maven JVM terminated unexpectedly with exit code 137 Not sending mail to unregistered user kirpic...@google.com Not sending mail to unregistered user k...@google.com
