See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/3216/display/redirect?page=changes>
Changes: [jbonofre] [BEAM-2276] Add windowing into default filename policy ------------------------------------------ [...truncated 5.43 MB...] [INFO] 2017-05-26T07:28:29.161Z: (144e0e520cd94ece): Executing operation PAssert$291/GroupGlobally/GroupDummyAndContents/Read+PAssert$291/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$291/GroupGlobally/Values/Values/Map+PAssert$291/GroupGlobally/ParDo(Concat)+PAssert$291/GetPane/Map+PAssert$291/RunChecks+PAssert$291/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:28:29.296Z: (5e775bd6648c84c3): Executing operation PAssert$292/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$292/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$292/GroupGlobally/GroupDummyAndContents/Reify+PAssert$292/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:29.301Z: (e5a8f65be4380d36): Executing operation PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$292/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$292/GroupGlobally/RewindowActuals/Window.Assign+PAssert$292/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$292/GroupGlobally/GroupDummyAndContents/Reify+PAssert$292/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:30.882Z: (e5a8f65be4380fe3): Executing operation PAssert$292/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:28:30.903Z: (e5a8f65be43800f5): Executing operation PAssert$292/GroupGlobally/GroupDummyAndContents/Read+PAssert$292/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$292/GroupGlobally/Values/Values/Map+PAssert$292/GroupGlobally/ParDo(Concat)+PAssert$292/GetPane/Map+PAssert$292/RunChecks+PAssert$292/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:28:32.280Z: (c11d50c09554bf74): Cleaning up. [INFO] 2017-05-26T07:28:32.285Z: (c11d50c09554b2d8): Stopping worker pool... [INFO] 2017-05-26T07:28:29.702Z: (7872995b0bd62864): Executing operation Combine.globally(SumInts)/View.AsIterable/CreateDataflowView [INFO] 2017-05-26T07:28:29.807Z: (7872995b0bd62e73): Executing operation Combine.globally(SumInts)/CreateVoid/Read(CreateSource)+Combine.globally(SumInts)/ProduceDefault+PAssert$280/GroupGlobally/Window.Into()/Window.Assign+PAssert$280/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$280/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$280/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] Job 2017-05-26_00_24_58-15993154761785787658 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_24_58-15993154761785787658. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-05-26T07:28:33.939Z: (7872995b0bd62c44): Executing operation PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:28:33.950Z: (7872995b0bd6291d): Executing operation PAssert$280/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:28:34.149Z: (7872995b0bd62f2c): Executing operation PAssert$280/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$280/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$280/GroupGlobally/GroupDummyAndContents/Reify+PAssert$280/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:34.155Z: (94d7f5fa7e2f78d4): Executing operation PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$280/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$280/GroupGlobally/RewindowActuals/Window.Assign+PAssert$280/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$280/GroupGlobally/GroupDummyAndContents/Reify+PAssert$280/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:34.471Z: (ffa4688e06b3b1ad): Executing operation PAssert$284/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:28:34.482Z: (ffa4688e06b3becf): Executing operation PAssert$284/GroupGlobally/GroupDummyAndContents/Read+PAssert$284/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$284/GroupGlobally/Values/Values/Map+PAssert$284/GroupGlobally/ParDo(Concat)+PAssert$284/GetPane/Map+PAssert$284/RunChecks+PAssert$284/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:28:37.402Z: (94d7f5fa7e2f7dd1): Executing operation PAssert$280/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:28:37.416Z: (94d7f5fa7e2f7303): Executing operation PAssert$280/GroupGlobally/GroupDummyAndContents/Read+PAssert$280/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$280/GroupGlobally/Values/Values/Map+PAssert$280/GroupGlobally/ParDo(Concat)+PAssert$280/GetPane/Map+PAssert$280/RunChecks+PAssert$280/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:28:37.142Z: (7d5780b6fd8cad4c): Executing operation View.AsSingleton/CreateDataflowView [INFO] 2017-05-26T07:28:37.221Z: (7d5780b6fd8ca518): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-05-26T07:28:37.224Z: (db45136d2ad9738b): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-05-26T07:28:37.562Z: (db45136d2ad97d39): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write [INFO] 2017-05-26T07:28:37.565Z: (7d5780b6fd8ca25b): 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-05-26T07:28:38.159Z: (f7068ef98c9853b8): Workers have started successfully. [INFO] 2017-05-26T07:28:40.294Z: (7f96ba3e085f0cb5): Executing operation View.AsSingleton/CreateDataflowView [INFO] 2017-05-26T07:28:40.435Z: (7f96ba3e085f0a51): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-05-26T07:28:40.439Z: (790bde3d31b69549): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-05-26T07:28:40.759Z: (790bde3d31b6924b): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write [INFO] 2017-05-26T07:28:40.764Z: (7f96ba3e085f0627): 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-05-26T07:28:40.841Z: (447651cac823bf8): Cleaning up. [INFO] 2017-05-26T07:28:40.932Z: (447651cac8233cc): Stopping worker pool... [INFO] 2017-05-26T07:28:45.071Z: (38d1559747faefc4): Workers have started successfully. [INFO] 2017-05-26T07:28:46.143Z: (db45136d2ad9731d): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-05-26T07:28:46.153Z: (db45136d2ad97060): Executing operation PAssert$288/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:28:46.356Z: (db45136d2ad97095): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+PAssert$288/GroupGlobally/Window.Into()/Window.Assign+PAssert$288/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$288/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$288/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$288/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$288/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:28:46.550Z: (7d5780b6fd8ca834): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-05-26T07:28:46.565Z: (7d5780b6fd8caa27): Executing operation PAssert$289/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:28:46.774Z: (7d5780b6fd8ca12c): 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$289/GroupGlobally/Window.Into()/Window.Assign+PAssert$289/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$289/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$289/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$289/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$289/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:28:47.101Z: (db45136d2ad97c28): Executing operation PAssert$288/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:28:47.115Z: (db45136d2ad9796b): Executing operation PAssert$288/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:28:47.218Z: (db45136d2ad979a0): Executing operation PAssert$288/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$288/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$288/GroupGlobally/GroupDummyAndContents/Reify+PAssert$288/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:47.224Z: (e2d6bb258b0235e3): Executing operation PAssert$288/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$288/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$288/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$288/GroupGlobally/RewindowActuals/Window.Assign+PAssert$288/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$288/GroupGlobally/GroupDummyAndContents/Reify+PAssert$288/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:48.543Z: (7d5780b6fd8ca705): Executing operation PAssert$289/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:28:48.558Z: (7d5780b6fd8ca8f8): Executing operation PAssert$289/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:28:48.755Z: (7d5780b6fd8caffd): Executing operation PAssert$289/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$289/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$289/GroupGlobally/GroupDummyAndContents/Reify+PAssert$289/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:48.759Z: (da652d955ff160f1): Executing operation PAssert$289/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$289/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$289/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$289/GroupGlobally/RewindowActuals/Window.Assign+PAssert$289/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$289/GroupGlobally/GroupDummyAndContents/Reify+PAssert$289/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:48.864Z: (e2d6bb258b0239de): Executing operation PAssert$288/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:28:48.876Z: (e2d6bb258b0231dc): Executing operation PAssert$288/GroupGlobally/GroupDummyAndContents/Read+PAssert$288/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$288/GroupGlobally/Values/Values/Map+PAssert$288/GroupGlobally/ParDo(Concat)+PAssert$288/GetPane/Map+PAssert$288/RunChecks+PAssert$288/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:28:49.425Z: (7d5780b6fd8ca0c4): Executing operation PAssert$289/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:28:49.439Z: (7d5780b6fd8ca702): Executing operation PAssert$289/GroupGlobally/GroupDummyAndContents/Read+PAssert$289/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$289/GroupGlobally/Values/Values/Map+PAssert$289/GroupGlobally/ParDo(Concat)+PAssert$289/GetPane/Map+PAssert$289/RunChecks+PAssert$289/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:28:49.837Z: (e89f2e9b9dd018db): Stopping worker pool... [INFO] 2017-05-26T07:28:51.899Z: (723d71eb3bee932c): Executing operation Combine.perKey(UniqueInts)/GroupByKey/Close [INFO] 2017-05-26T07:28:51.902Z: (a4d7268ae33070bd): Executing operation Combine.globally(UniqueInts)/Combine.perKey(UniqueInts)/GroupByKey/Close [INFO] 2017-05-26T07:28:51.913Z: (a4d7268ae33075e4): Executing operation PAssert$295/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:28:51.916Z: (723d71eb3bee9ca9): Executing operation PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:28:52.110Z: (a4d7268ae33077b6): Executing operation Combine.perKey(UniqueInts)/GroupByKey/Read+Combine.perKey(UniqueInts)/Combine.GroupedValues+Combine.perKey(UniqueInts)/Combine.GroupedValues/Extract+PAssert$295/GroupGlobally/Window.Into()/Window.Assign+PAssert$295/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$295/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$295/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$295/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$295/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:28:52.115Z: (723d71eb3bee93b4): 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$294/GroupGlobally/Window.Into()/Window.Assign+PAssert$294/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+Combine.globally(UniqueInts)/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+PAssert$294/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$294/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:28:55.206Z: (a4d7268ae3307be5): Executing operation PAssert$295/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:28:55.216Z: (a4d7268ae330710c): Executing operation PAssert$295/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:28:54.008Z: (790bde3d31b6982a): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-05-26T07:28:54.017Z: (790bde3d31b69a1f): Executing operation PAssert$285/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:28:54.219Z: (790bde3d31b69372): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+PAssert$285/GroupGlobally/Window.Into()/Window.Assign+PAssert$285/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$285/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$285/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$285/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$285/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:28:54.436Z: (7f96ba3e085f0c5c): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-05-26T07:28:54.445Z: (7f96ba3e085f03c3): Executing operation PAssert$286/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:28:54.645Z: (7f96ba3e085f0374): 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$286/GroupGlobally/Window.Into()/Window.Assign+PAssert$286/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$286/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$286/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$286/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$286/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:28:55.991Z: (790bde3d31b69797): Executing operation PAssert$285/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:28:56.001Z: (790bde3d31b6998c): Executing operation PAssert$285/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:28:55.413Z: (a4d7268ae33078fd): Executing operation PAssert$295/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$295/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$295/GroupGlobally/GroupDummyAndContents/Reify+PAssert$295/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:55.418Z: (5a06d855eba91baa): Executing operation PAssert$295/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$295/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$295/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$295/GroupGlobally/RewindowActuals/Window.Assign+PAssert$295/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$295/GroupGlobally/GroupDummyAndContents/Reify+PAssert$295/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:57.237Z: (723d71eb3bee99a1): Executing operation Combine.globally(UniqueInts)/CreateVoid/Read(CreateSource)+Combine.globally(UniqueInts)/ProduceDefault+PAssert$294/GroupGlobally/Window.Into()/Window.Assign+PAssert$294/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$294/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$294/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:28:56.197Z: (790bde3d31b692df): Executing operation PAssert$285/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$285/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$285/GroupGlobally/GroupDummyAndContents/Reify+PAssert$285/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:56.201Z: (ffa4688e06b3b95a): Executing operation PAssert$285/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$285/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$285/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$285/GroupGlobally/RewindowActuals/Window.Assign+PAssert$285/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$285/GroupGlobally/GroupDummyAndContents/Reify+PAssert$285/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:56.293Z: (7f96ba3e085f09a9): Executing operation PAssert$286/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:28:56.307Z: (7f96ba3e085f0110): Executing operation PAssert$286/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:28:56.424Z: (7f96ba3e085f00c1): Executing operation PAssert$286/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$286/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$286/GroupGlobally/GroupDummyAndContents/Reify+PAssert$286/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:56.428Z: (ecf516d5ceb6c385): Executing operation PAssert$286/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$286/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$286/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$286/GroupGlobally/RewindowActuals/Window.Assign+PAssert$286/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$286/GroupGlobally/GroupDummyAndContents/Reify+PAssert$286/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:58.211Z: (a4d7268ae33075a8): Executing operation PAssert$295/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:28:58.223Z: (a4d7268ae33070ee): Executing operation PAssert$295/GroupGlobally/GroupDummyAndContents/Read+PAssert$295/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$295/GroupGlobally/Values/Values/Map+PAssert$295/GroupGlobally/ParDo(Concat)+PAssert$295/GetPane/Map+PAssert$295/RunChecks+PAssert$295/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:28:59.105Z: (ffa4688e06b3ba2f): Executing operation PAssert$285/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:28:59.117Z: (ffa4688e06b3b751): Executing operation PAssert$285/GroupGlobally/GroupDummyAndContents/Read+PAssert$285/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$285/GroupGlobally/Values/Values/Map+PAssert$285/GroupGlobally/ParDo(Concat)+PAssert$285/GetPane/Map+PAssert$285/RunChecks+PAssert$285/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:28:59.205Z: (ecf516d5ceb6c4e6): Executing operation PAssert$286/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:28:59.217Z: (ecf516d5ceb6c240): Executing operation PAssert$286/GroupGlobally/GroupDummyAndContents/Read+PAssert$286/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$286/GroupGlobally/Values/Values/Map+PAssert$286/GroupGlobally/ParDo(Concat)+PAssert$286/GetPane/Map+PAssert$286/RunChecks+PAssert$286/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:29:01.260Z: (723d71eb3bee9df6): Executing operation PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:29:01.269Z: (723d71eb3bee9773): Executing operation PAssert$294/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:29:01.469Z: (723d71eb3bee9e7e): Executing operation PAssert$294/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$294/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$294/GroupGlobally/GroupDummyAndContents/Reify+PAssert$294/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:01.473Z: (5a06d855eba912ba): Executing operation PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$294/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$294/GroupGlobally/RewindowActuals/Window.Assign+PAssert$294/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$294/GroupGlobally/GroupDummyAndContents/Reify+PAssert$294/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:28:59.953Z: (80d2de7023c146e2): Cleaning up. [INFO] 2017-05-26T07:28:59.957Z: (80d2de7023c149c6): Stopping worker pool... [INFO] 2017-05-26T07:29:02.527Z: (a2b51f0a9da7bca3): Executing operation Combine.perKey(MeanInts)/GroupByKey/Close [INFO] 2017-05-26T07:29:02.530Z: (42079670098b9233): Executing operation Combine.globally(MeanInts)/Combine.perKey(MeanInts)/GroupByKey/Close [INFO] 2017-05-26T07:29:02.540Z: (42079670098b9096): Executing operation PAssert$297/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:29:02.543Z: (a2b51f0a9da7b95a): Executing operation PAssert$296/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:29:02.737Z: (42079670098b9c70): Executing operation Combine.perKey(MeanInts)/GroupByKey/Read+Combine.perKey(MeanInts)/Combine.GroupedValues+Combine.perKey(MeanInts)/Combine.GroupedValues/Extract+PAssert$297/GroupGlobally/Window.Into()/Window.Assign+PAssert$297/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$297/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$297/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$297/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$297/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:29:02.743Z: (a2b51f0a9da7b83b): 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$296/GroupGlobally/Window.Into()/Window.Assign+PAssert$296/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+Combine.globally(MeanInts)/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+PAssert$296/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$296/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$296/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$296/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:29:04.758Z: (a40db11423b7be04): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Close [INFO] 2017-05-26T07:29:04.767Z: (a40db11423b7be3c): Executing operation View.AsSingleton/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-05-26T07:29:06.552Z: (5a06d855eba91059): Executing operation PAssert$294/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:29:06.565Z: (5a06d855eba918ff): Executing operation PAssert$294/GroupGlobally/GroupDummyAndContents/Read+PAssert$294/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$294/GroupGlobally/Values/Values/Map+PAssert$294/GroupGlobally/ParDo(Concat)+PAssert$294/GetPane/Map+PAssert$294/RunChecks+PAssert$294/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:29:04.769Z: (7c6d082247ff661a): Executing operation PAssert$298/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:29:04.966Z: (f75633580a65ae86): Autoscaling: Attempting to upscale worker pool to 2. [INFO] 2017-05-26T07:29:04.983Z: (7c6d082247ff620f): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Read+Sum/Combine.perKey(SumInts)/Combine.GroupedValues+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract+Sum/Values/Values/Map+Sum/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+View.AsSingleton/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write+PAssert$298/GroupGlobally/Window.Into()/Window.Assign+PAssert$298/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$298/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$298/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$298/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$298/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:29:05.768Z: (42079670098b98fb): Executing operation PAssert$297/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:29:05.783Z: (42079670098b975e): Executing operation PAssert$297/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:29:05.972Z: (42079670098b9373): Executing operation PAssert$297/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$297/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$297/GroupGlobally/GroupDummyAndContents/Reify+PAssert$297/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:05.977Z: (28fe5657c7dea415): Executing operation PAssert$297/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$297/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$297/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$297/GroupGlobally/RewindowActuals/Window.Assign+PAssert$297/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$297/GroupGlobally/GroupDummyAndContents/Reify+PAssert$297/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:08.592Z: (7c6d082247ff63d7): Executing operation Sum/View.AsIterable/CreateDataflowView [INFO] 2017-05-26T07:29:08.667Z: (7c6d082247ff6171): Executing operation Sum/CreateVoid/Read(CreateSource)+Sum/ProduceDefault+View.AsSingleton/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write+PAssert$298/GroupGlobally/Window.Into()/Window.Assign+PAssert$298/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$298/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$298/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$298/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$298/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:29:09.043Z: (6d4ee158683eb5a0): Cleaning up. [INFO] 2017-05-26T07:29:09.133Z: (6d4ee158683eb8f4): Stopping worker pool... [INFO] 2017-05-26T07:29:11.151Z: (28fe5657c7dea9b2): Executing operation PAssert$297/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:29:11.164Z: (28fe5657c7deaf24): Executing operation PAssert$297/GroupGlobally/GroupDummyAndContents/Read+PAssert$297/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$297/GroupGlobally/Values/Values/Map+PAssert$297/GroupGlobally/ParDo(Concat)+PAssert$297/GetPane/Map+PAssert$297/RunChecks+PAssert$297/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:29:12.813Z: (7c6d082247ff6bc1): Executing operation View.AsSingleton/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-05-26T07:29:12.816Z: (a40db11423b7b8cf): Executing operation PAssert$298/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:29:12.825Z: (7c6d082247ff659f): Executing operation View.AsSingleton/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-05-26T07:29:12.828Z: (a40db11423b7b700): Executing operation PAssert$298/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:29:13.020Z: (a40db11423b7b977): Executing operation PAssert$298/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$298/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$298/GroupGlobally/GroupDummyAndContents/Reify+PAssert$298/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:13.024Z: (d473329648f37b11): Executing operation PAssert$298/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$298/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$298/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$298/GroupGlobally/RewindowActuals/Window.Assign+PAssert$298/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$298/GroupGlobally/GroupDummyAndContents/Reify+PAssert$298/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:12.435Z: (a2b51f0a9da7b590): Executing operation Combine.globally(MeanInts)/View.AsIterable/CreateDataflowView [INFO] 2017-05-26T07:29:12.507Z: (a2b51f0a9da7b642): Executing operation Combine.globally(MeanInts)/CreateVoid/Read(CreateSource)+Combine.globally(MeanInts)/ProduceDefault+PAssert$296/GroupGlobally/Window.Into()/Window.Assign+PAssert$296/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$296/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$296/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$296/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$296/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-05-26T07:29:15.425Z: (a2b51f0a9da7b181): Executing operation PAssert$296/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:29:15.437Z: (a2b51f0a9da7be38): Executing operation PAssert$296/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:29:15.635Z: (a2b51f0a9da7bd19): Executing operation PAssert$296/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$296/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$296/GroupGlobally/GroupDummyAndContents/Reify+PAssert$296/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:15.641Z: (42079670098b9ffe): Executing operation PAssert$296/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$296/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$296/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$296/GroupGlobally/RewindowActuals/Window.Assign+PAssert$296/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$296/GroupGlobally/GroupDummyAndContents/Reify+PAssert$296/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:20.730Z: (42079670098b9c89): Executing operation PAssert$296/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:29:20.756Z: (42079670098b9b27): Executing operation PAssert$296/GroupGlobally/GroupDummyAndContents/Read+PAssert$296/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$296/GroupGlobally/Values/Values/Map+PAssert$296/GroupGlobally/ParDo(Concat)+PAssert$296/GetPane/Map+PAssert$296/RunChecks+PAssert$296/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:29:23.353Z: (dd08f8f01e9df4c4): Cleaning up. [INFO] 2017-05-26T07:29:23.397Z: (dd08f8f01e9dfbe0): Stopping worker pool... [INFO] 2017-05-26T07:29:23.592Z: (7c6d082247ff641d): Executing operation View.AsSingleton/CreateDataflowView [INFO] 2017-05-26T07:29:23.857Z: (7c6d082247ff63ce): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-05-26T07:29:23.860Z: (63313616cb870e01): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-05-26T07:29:24.162Z: (7c6d082247ff6b46): 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-05-26T07:29:24.165Z: (63313616cb8702a9): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write [INFO] 2017-05-26T07:29:27.396Z: (7c6d082247ff6119): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-05-26T07:29:25.887Z: (d280a18315df482): Worker pool stopped. [INFO] 2017-05-26T07:29:27.408Z: (7c6d082247ff6c9c): Executing operation PAssert$300/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:29:27.605Z: (7c6d082247ff6891): 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$300/GroupGlobally/Window.Into()/Window.Assign+PAssert$300/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$300/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$300/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$300/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$300/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] Job 2017-05-26_00_24_56-8874957593364776564 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_24_56-8874957593364776564. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-05-26T07:29:29.431Z: (e941625b115b056b): Worker pool stopped. [INFO] 2017-05-26T07:29:29.568Z: (7c6d082247ff6e64): Executing operation PAssert$300/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:29:29.578Z: (7c6d082247ff69e7): Executing operation PAssert$300/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:29:29.779Z: (7c6d082247ff65dc): Executing operation PAssert$300/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$300/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$300/GroupGlobally/GroupDummyAndContents/Reify+PAssert$300/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:29.784Z: (a40db11423b7bfc4): Executing operation PAssert$300/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$300/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$300/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$300/GroupGlobally/RewindowActuals/Window.Assign+PAssert$300/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$300/GroupGlobally/GroupDummyAndContents/Reify+PAssert$300/GroupGlobally/GroupDummyAndContents/Write [INFO] Job 2017-05-26_00_25_40-15529090652539776525 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_25_40-15529090652539776525. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-05-26T07:29:34.311Z: (f75633580a65a0e7): Autoscaling: Resized worker pool from 1 to 2. [INFO] 2017-05-26T07:29:34.314Z: (f75633580a65abf9): Autoscaling: Raised the number of workers to 2 based on the rate of progress in the currently running step(s). [INFO] 2017-05-26T07:29:35.879Z: (7c6d082247ff67f3): Executing operation PAssert$300/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:29:35.891Z: (7c6d082247ff61d1): Executing operation PAssert$300/GroupGlobally/GroupDummyAndContents/Read+PAssert$300/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$300/GroupGlobally/Values/Values/Map+PAssert$300/GroupGlobally/ParDo(Concat)+PAssert$300/GetPane/Map+PAssert$300/RunChecks+PAssert$300/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:29:39.124Z: (df85d452e94cbcaf): Worker pool stopped. [INFO] 2017-05-26T07:29:40.939Z: (447651cac8239ab): Worker pool stopped. [INFO] 2017-05-26T07:29:42.293Z: (c11d50c09554bd63): Worker pool stopped. [INFO] Job 2017-05-26_00_26_06-12816802187845592579 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_26_06-12816802187845592579. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-05-26_00_25_46-10078164604884233851 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_25_46-10078164604884233851. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-05-26T07:29:44.841Z: (63313616cb870843): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-05-26T07:29:44.849Z: (63313616cb8704f4): Executing operation PAssert$299/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-05-26T07:29:45.052Z: (63313616cb870ceb): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+PAssert$299/GroupGlobally/Window.Into()/Window.Assign+PAssert$299/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$299/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$299/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$299/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$299/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] Job 2017-05-26_00_25_49-10656891872490430862 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_25_49-10656891872490430862. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-05-26T07:29:49.106Z: (63313616cb870285): Executing operation PAssert$299/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-05-26T07:29:49.115Z: (63313616cb870f36): Executing operation PAssert$299/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-05-26T07:29:49.265Z: (d473329648f379d2): Executing operation PAssert$298/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:29:49.276Z: (d473329648f372ec): Executing operation PAssert$298/GroupGlobally/GroupDummyAndContents/Read+PAssert$298/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$298/GroupGlobally/Values/Values/Map+PAssert$298/GroupGlobally/ParDo(Concat)+PAssert$298/GetPane/Map+PAssert$298/RunChecks+PAssert$298/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:29:49.319Z: (63313616cb87072d): Executing operation PAssert$299/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$299/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$299/GroupGlobally/GroupDummyAndContents/Reify+PAssert$299/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:49.324Z: (944809bfb3e67ad): Executing operation PAssert$299/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$299/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$299/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$299/GroupGlobally/RewindowActuals/Window.Assign+PAssert$299/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$299/GroupGlobally/GroupDummyAndContents/Reify+PAssert$299/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-05-26T07:29:49.743Z: (944809bfb3e6c34): Executing operation PAssert$299/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-05-26T07:29:49.756Z: (944809bfb3e646a): Executing operation PAssert$299/GroupGlobally/GroupDummyAndContents/Read+PAssert$299/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$299/GroupGlobally/Values/Values/Map+PAssert$299/GroupGlobally/ParDo(Concat)+PAssert$299/GetPane/Map+PAssert$299/RunChecks+PAssert$299/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-05-26T07:29:50.341Z: (883843ee6ccf3cd): Cleaning up. [INFO] 2017-05-26T07:29:50.417Z: (883843ee6ccf571): Stopping worker pool... [INFO] 2017-05-26T07:30:09.851Z: (e89f2e9b9dd0170a): Worker pool stopped. [INFO] Job 2017-05-26_00_25_49-1559533321364304128 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_25_49-1559533321364304128. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-05-26T07:30:19.139Z: (6d4ee158683eb773): Worker pool stopped. [INFO] 2017-05-26T07:30:19.968Z: (80d2de7023c143f1): Worker pool stopped. [INFO] Job 2017-05-26_00_26_52-2696092698542619421 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_26_52-2696092698542619421. Found 2 success, 0 failures out of 2 expected assertions. [INFO] Job 2017-05-26_00_25_47-9352916638408721354 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_25_47-9352916638408721354. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-05-26T07:30:43.419Z: (dd08f8f01e9df535): Worker pool stopped. [INFO] Job 2017-05-26_00_26_53-12768212239518491968 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_26_53-12768212239518491968. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-05-26T07:31:20.424Z: (883843ee6ccf2ac): Worker pool stopped. [INFO] Job 2017-05-26_00_26_54-3322898259045279430 finished with status DONE. [INFO] Success result for Dataflow job 2017-05-26_00_26_54-3322898259045279430. Found 3 success, 0 failures out of 3 expected assertions. 2017-05-26T07:31:25.864 [INFO] Running org.apache.beam.sdk.transforms.CombineTest 2017-05-26T07:31:26.028 [INFO] Tests run: 21, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 536.749 s - in org.apache.beam.sdk.transforms.CombineTest 2017-05-26T07:31:26.029 [INFO] Running org.apache.beam.sdk.values.PDoneTest 2017-05-26T07:31:26.035 [WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0.001 s - in org.apache.beam.sdk.values.PDoneTest 2017-05-26T07:31:26.038 [INFO] 2017-05-26T07:31:26.038 [INFO] Results: 2017-05-26T07:31:26.038 [INFO] 2017-05-26T07:31:26.038 [WARNING] Tests run: 244, Failures: 0, Errors: 0, Skipped: 1 2017-05-26T07:31:26.038 [INFO] [JENKINS] Recording test results 2017-05-26T07:31:28.639 [INFO] 2017-05-26T07:31:28.639 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-05-26T07:31:28.812 [INFO] No dependency problems found [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled 2017-05-26T07:31:38.639 [INFO] ------------------------------------------------------------------------ 2017-05-26T07:31:38.639 [INFO] Reactor Summary: 2017-05-26T07:31:38.639 [INFO] 2017-05-26T07:31:38.639 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 19.534 s] 2017-05-26T07:31:38.639 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 8.584 s] 2017-05-26T07:31:38.639 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 1.408 s] 2017-05-26T07:31:38.639 [INFO] Apache Beam :: SDKs :: Common ...................... SUCCESS [ 1.283 s] 2017-05-26T07:31:38.639 [INFO] Apache Beam :: SDKs :: Common :: Fn API ............ SUCCESS [ 10.570 s] 2017-05-26T07:31:38.639 [INFO] Apache Beam :: SDKs :: Common :: Runner API ........ SUCCESS [ 3.276 s] 2017-05-26T07:31:38.639 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 1.197 s] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [01:26 min] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 1.296 s] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 1.294 s] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [ 11.098 s] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [ 21.899 s] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [03:00 min] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 1.663 s] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [ 19.843 s] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 14.329 s] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [ 56.395 s] 2017-05-26T07:31:38.640 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:24 h] 2017-05-26T07:31:38.640 [INFO] ------------------------------------------------------------------------ 2017-05-26T07:31:38.640 [INFO] BUILD SUCCESS 2017-05-26T07:31:38.640 [INFO] ------------------------------------------------------------------------ 2017-05-26T07:31:38.640 [INFO] Total time: 01:32 h 2017-05-26T07:31:38.640 [INFO] Finished at: 2017-05-26T07:31:38+00:00 2017-05-26T07:31:39.805 [INFO] Final Memory: 314M/2053M 2017-05-26T07:31:39.805 [INFO] ------------------------------------------------------------------------ Waiting for Jenkins to finish collecting data channel stopped
