See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/3983/display/redirect>
------------------------------------------ [...truncated 8.44 MB...] [INFO] 2017-09-17T07:26:19.242Z: (4c4c43e9a10be65): Executing operation PAssert$311/GroupGlobally/GroupDummyAndContents/Read+PAssert$311/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$311/GroupGlobally/Values/Values/Map+PAssert$311/GroupGlobally/ParDo(Concat)+PAssert$311/GetPane/Map+PAssert$311/RunChecks+PAssert$311/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-09-17T07:26:21.041Z: (b03841bd8caa6666): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Close [INFO] 2017-09-17T07:26:21.058Z: (b03841bd8caa6abb): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-09-17T07:26:21.069Z: (48b872ba2d90a6fa): Executing operation PAssert$318/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:26:21.117Z: (48b872ba2d90ab4e): 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$318/GroupGlobally/Window.Into()/Window.Assign+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+PAssert$318/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$318/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$318/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$318/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$318/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-09-17T07:26:23.093Z: (1b48c1db7fd0e0f1): Cleaning up. [INFO] 2017-09-17T07:26:23.098Z: (1b48c1db7fd0e255): Stopping worker pool... [INFO] 2017-09-17T07:26:25.404Z: (fcdfdb77db1c5fba): Executing operation Combine.perKey(UniqueInts)/GroupByKey/Close [INFO] 2017-09-17T07:26:25.425Z: (e9e03cb7bcd0152b): Executing operation Combine.globally(UniqueInts)/Combine.perKey(UniqueInts)/GroupByKey/Close [INFO] 2017-09-17T07:26:25.456Z: (fcdfdb77db1c5d32): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:26:25.485Z: (e9e03cb7bcd013a3): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:26:25.570Z: (e9e03cb7bcd01b9e): Executing operation Combine.perKey(UniqueInts)/GroupByKey/Read+Combine.perKey(UniqueInts)/Combine.GroupedValues+Combine.perKey(UniqueInts)/Combine.GroupedValues/Extract+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-09-17T07:26:25.593Z: (fcdfdb77db1c56de): 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$325/GroupGlobally/Window.Into()/Window.Assign+PAssert$325/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+Combine.globally(UniqueInts)/View.AsIterable/View.CreatePCollectionView/ParDo(ToIsmRecordForGlobalWindow)+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-09-17T07:26:24.944Z: (8914df7ab518299f): Executing operation PAssert$321/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:26:24.967Z: (6cce6381907c922a): Executing operation PAssert$321/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:26:25.033Z: (8914df7ab5182f97): 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-09-17T07:26:25.058Z: (6cce6381907c953e): 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-09-17T07:26:26.383Z: (8ba6841bf7538ed7): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:26.411Z: (4c05a518676ee23a): 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-09-17T07:26:27.109Z: (ec43a94e8d7b4605): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-09-17T07:26:27.145Z: (886914d9e4c9df79): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-09-17T07:26:29.915Z: (e8db63a9f80d92ea): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:26:29.946Z: (e9e03cb7bcd0102c): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:26:28.875Z: (b6a972fb4d7ce825): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-09-17T07:26:28.906Z: (b6a972fb4d7ce53c): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-09-17T07:26:29.380Z: (48b872ba2d90afa2): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-09-17T07:26:29.401Z: (b03841bd8caa6719): Executing operation PAssert$318/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:26:29.426Z: (b03841bd8caa6e81): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-09-17T07:26:29.450Z: (48b872ba2d90ae2a): Executing operation PAssert$318/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:26:29.506Z: (b03841bd8caa6418): 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-09-17T07:26:29.526Z: (7b4680817b02885f): Executing operation PAssert$318/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$318/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$318/GroupGlobally/GroupDummyAndContents/Reify+PAssert$318/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:26:29.543Z: (48b872ba2d90a625): Executing operation PAssert$318/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$318/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$318/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$318/GroupGlobally/RewindowActuals/Window.Assign+PAssert$318/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$318/GroupGlobally/GroupDummyAndContents/Reify+PAssert$318/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:26:30.545Z: (b4e1c0261c01576): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-09-17T07:26:30.570Z: (c5692de449a462f): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-09-17T07:26:31.199Z: (1e4b0d5d22e4c6d0): Cleaning up. [INFO] 2017-09-17T07:26:31.210Z: (1e4b0d5d22e4cc74): Stopping worker pool... [INFO] 2017-09-17T07:26:30.051Z: (fcdfdb77db1c59fc): 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-09-17T07:26:30.076Z: (f2796fe3324aa449): 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-09-17T07:26:30.109Z: (e9e03cb7bcd01c58): Executing operation Combine.globally(UniqueInts)/View.AsIterable/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-09-17T07:26:30.200Z: (e9e03cb7bcd01a0c): Executing operation Combine.globally(UniqueInts)/CreateVoid/Read(CreateSource)+Combine.globally(UniqueInts)/ProduceDefault+PAssert$325/GroupGlobally/Window.Into()/Window.Assign+PAssert$325/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$325/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$325/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-09-17T07:26:35.667Z: (c5692de449a46ed): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-09-17T07:26:35.786Z: (b4e1c0261c01b56): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-09-17T07:26:35.800Z: (c5692de449a4aee): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-09-17T07:26:35.933Z: (c5692de449a491f): 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-09-17T07:26:35.957Z: (c8d6e0ad81de55db): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write [INFO] 2017-09-17T07:26:33.774Z: (e9e03cb7bcd01207): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:26:33.805Z: (e8db63a9f80d9b30): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:26:33.882Z: (f2796fe3324aa4db): 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-09-17T07:26:33.906Z: (e9e03cb7bcd01ac6): 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-09-17T07:26:35.611Z: (8914df7ab5182b4a): Executing operation PAssert$321/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:35.632Z: (8914df7ab5182683): 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-09-17T07:26:37.515Z: (b6a972fb4d7ce17c): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-09-17T07:26:37.604Z: (b6a972fb4d7cef32): Executing operation PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:26:37.710Z: (5b64013c98c8b29f): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-09-17T07:26:37.738Z: (c8d6e0ad81de5bfd): Executing operation PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:26:37.791Z: (5b64013c98c8bc04): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+PAssert$330/GroupGlobally/Window.Into()/Window.Assign+PAssert$330/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$330/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$330/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-09-17T07:26:38.355Z: (e9e03cb7bcd01f54): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:38.375Z: (e8db63a9f80d92e9): 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-09-17T07:26:37.625Z: (767dd2cd89e03a99): Executing operation PAssert$316/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:26:37.668Z: (f7d3e53a1386d0db): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.globally(TestCombineFnWithContext)/Values/Values/Map+PAssert$317/GroupGlobally/Window.Into()/Window.Assign+PAssert$317/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$317/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$317/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-09-17T07:26:37.710Z: (767dd2cd89e03c65): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+PAssert$316/GroupGlobally/Window.Into()/Window.Assign+PAssert$316/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$316/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$316/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$316/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$316/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-09-17T07:26:39.811Z: (c8d6e0ad81de5b92): Executing operation PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:26:39.833Z: (c8d6e0ad81de528a): Executing operation PAssert$330/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:26:39.894Z: (5b64013c98c8b761): Executing operation PAssert$330/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$330/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$330/GroupGlobally/GroupDummyAndContents/Reify+PAssert$330/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:26:39.915Z: (c8d6e0ad81de521f): Executing operation PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$330/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$330/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$330/GroupGlobally/RewindowActuals/Window.Assign+PAssert$330/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$330/GroupGlobally/GroupDummyAndContents/Reify+PAssert$330/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:26:38.930Z: (886914d9e4c9d1b9): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-09-17T07:26:39.041Z: (886914d9e4c9da25): Executing operation PAssert$324/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:26:39.060Z: (ec43a94e8d7b4865): Executing operation PAssert$323/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:26:39.095Z: (886914d9e4c9d888): 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$324/GroupGlobally/Window.Into()/Window.Assign+PAssert$324/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$324/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$324/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$324/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$324/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-09-17T07:26:39.139Z: (ec43a94e8d7b4e36): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+PAssert$323/GroupGlobally/Window.Into()/Window.Assign+PAssert$323/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$323/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$323/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$323/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$323/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-09-17T07:26:39.219Z: (f2796fe3324aac69): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:39.239Z: (fcdfdb77db1c51df): 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-09-17T07:26:42.304Z: (b03841bd8caa6cc2): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-09-17T07:26:42.321Z: (b03841bd8caa673d): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-09-17T07:26:44.232Z: (4f25bf3cbafb8e04): Cleaning up. [INFO] 2017-09-17T07:26:44.241Z: (4f25bf3cbafb8960): Stopping worker pool... [INFO] 2017-09-17T07:26:45.377Z: (c5692de449a4e39): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-09-17T07:26:45.397Z: (5b64013c98c8b887): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:26:45.458Z: (c5692de449a400c): 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$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-09-17T07:26:45.490Z: (5b64013c98c8b16e): Executing operation PAssert$330/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:45.518Z: (5b64013c98c8ba01): Executing operation PAssert$330/GroupGlobally/GroupDummyAndContents/Read+PAssert$330/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$330/GroupGlobally/Values/Values/Map+PAssert$330/GroupGlobally/ParDo(Concat)+PAssert$330/GetPane/Map+PAssert$330/RunChecks+PAssert$330/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-09-17T07:26:46.576Z: (c5692de449a446c): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:26:46.602Z: (c8d6e0ad81de58ac): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:26:46.665Z: (c8d6e0ad81de5841): 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-09-17T07:26:46.688Z: (c5692de449a463f): 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-09-17T07:26:46.785Z: (b9b8d8623c82d207): Executing operation PAssert$323/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:26:46.817Z: (b9b8d8623c82d44f): Executing operation PAssert$323/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:26:46.906Z: (ec43a94e8d7b4711): 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-09-17T07:26:46.925Z: (b9b8d8623c82da03): 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-09-17T07:26:47.196Z: (60f433334f939290): Cleaning up. [INFO] 2017-09-17T07:26:47.201Z: (60f433334f939d8c): Stopping worker pool... [INFO] 2017-09-17T07:26:48.228Z: (b03841bd8caa661f): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-09-17T07:26:48.300Z: (b03841bd8caa69e5): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-09-17T07:26:48.321Z: (48b872ba2d90a3ec): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-09-17T07:26:48.389Z: (b03841bd8caa6d0a): 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-09-17T07:26:48.697Z: (b876eefbe075de02): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write [INFO] 2017-09-17T07:26:48.728Z: (7b4680817b028ec6): Executing operation PAssert$318/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:48.757Z: (e7676baab7bbb215): Executing operation PAssert$318/GroupGlobally/GroupDummyAndContents/Read+PAssert$318/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$318/GroupGlobally/Values/Values/Map+PAssert$318/GroupGlobally/ParDo(Concat)+PAssert$318/GetPane/Map+PAssert$318/RunChecks+PAssert$318/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-09-17T07:26:48.989Z: (c5692de449a4fb5): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:49.029Z: (c5692de449a452a): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Read+PAssert$331/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$331/GroupGlobally/Values/Values/Map+PAssert$331/GroupGlobally/ParDo(Concat)+PAssert$331/GetPane/Map+PAssert$331/RunChecks+PAssert$331/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-09-17T07:26:49.392Z: (767dd2cd89e032a4): Executing operation PAssert$316/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:26:49.414Z: (b6a972fb4d7ce642): Executing operation PAssert$316/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:26:49.500Z: (b6a972fb4d7ced1d): Executing operation PAssert$316/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$316/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$316/GroupGlobally/GroupDummyAndContents/Reify+PAssert$316/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:26:49.525Z: (767dd2cd89e0382b): Executing operation PAssert$316/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$316/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$316/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$316/GroupGlobally/RewindowActuals/Window.Assign+PAssert$316/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$316/GroupGlobally/GroupDummyAndContents/Reify+PAssert$316/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:26:48.818Z: (be5dcff9027ffe4f): Executing operation PAssert$324/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:26:48.848Z: (886914d9e4c9dd72): Executing operation PAssert$324/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:26:48.920Z: (be5dcff9027ff807): Executing operation PAssert$324/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$324/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$324/GroupGlobally/GroupDummyAndContents/Reify+PAssert$324/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:26:48.946Z: (886914d9e4c9d626): Executing operation PAssert$324/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$324/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$324/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$324/GroupGlobally/RewindowActuals/Window.Assign+PAssert$324/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$324/GroupGlobally/GroupDummyAndContents/Reify+PAssert$324/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:26:53.587Z: (8462dc2fd13ac6e6): Cleaning up. [INFO] 2017-09-17T07:26:53.591Z: (8462dc2fd13ac84a): Stopping worker pool... [INFO] 2017-09-17T07:26:56.508Z: (886914d9e4c9dac8): Executing operation PAssert$324/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:56.523Z: (886914d9e4c9d107): 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-09-17T07:26:57.755Z: (b6a972fb4d7ce0da): Executing operation PAssert$316/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:57.774Z: (b6a972fb4d7cedf1): Executing operation PAssert$316/GroupGlobally/GroupDummyAndContents/Read+PAssert$316/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$316/GroupGlobally/Values/Values/Map+PAssert$316/GroupGlobally/ParDo(Concat)+PAssert$316/GetPane/Map+PAssert$316/RunChecks+PAssert$316/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-09-17T07:26:57.594Z: (f9396e68129f5292): Executing operation PAssert$322/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:26:57.612Z: (f9396e68129f5f53): Executing operation PAssert$322/GroupGlobally/GroupDummyAndContents/Read+PAssert$322/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$322/GroupGlobally/Values/Values/Map+PAssert$322/GroupGlobally/ParDo(Concat)+PAssert$322/GetPane/Map+PAssert$322/RunChecks+PAssert$322/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-09-17T07:27:02.269Z: (f7d3e53a1386daa5): Executing operation PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:27:02.287Z: (f7d3e53a1386dc6d): Executing operation PAssert$317/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:27:02.342Z: (f7d3e53a1386d8e1): Executing operation PAssert$317/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$317/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$317/GroupGlobally/GroupDummyAndContents/Reify+PAssert$317/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:27:02.362Z: (767dd2cd89e039f7): Executing operation PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$317/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$317/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$317/GroupGlobally/RewindowActuals/Window.Assign+PAssert$317/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$317/GroupGlobally/GroupDummyAndContents/Reify+PAssert$317/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:27:03.606Z: (f5baed7ce1ffaf11): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-09-17T07:27:03.608Z: (f5baed7ce1ffa163): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-09-17T07:27:05.486Z: (f9396e68129f59ba): Executing operation PAssert$323/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:27:05.506Z: (f9396e68129f567b): 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-09-17T07:27:05.721Z: (b876eefbe075d656): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-09-17T07:27:05.744Z: (b876eefbe075d66e): Executing operation PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:27:05.814Z: (b876eefbe075deaa): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+PAssert$319/GroupGlobally/Window.Into()/Window.Assign+PAssert$319/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$319/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$319/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-09-17T07:27:07.914Z: (12c96d3adf8baa90): Cleaning up. [INFO] 2017-09-17T07:27:07.919Z: (12c96d3adf8ba09c): Stopping worker pool... [INFO] 2017-09-17T07:27:09.473Z: (b876eefbe075d907): Executing operation PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:27:09.515Z: (b876eefbe075d91f): Executing operation PAssert$319/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:27:09.588Z: (b876eefbe075d15b): Executing operation PAssert$319/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$319/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$319/GroupGlobally/GroupDummyAndContents/Reify+PAssert$319/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:27:09.603Z: (4743a015b03062fb): Executing operation PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$319/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$319/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$319/GroupGlobally/RewindowActuals/Window.Assign+PAssert$319/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$319/GroupGlobally/GroupDummyAndContents/Reify+PAssert$319/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:27:09.857Z: (f7d3e53a1386d238): Executing operation PAssert$317/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:27:09.877Z: (767dd2cd89e03395): Executing operation PAssert$317/GroupGlobally/GroupDummyAndContents/Read+PAssert$317/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$317/GroupGlobally/Values/Values/Map+PAssert$317/GroupGlobally/ParDo(Concat)+PAssert$317/GetPane/Map+PAssert$317/RunChecks+PAssert$317/VerifyAssertions/ParDo(DefaultConclude) [INFO] Job 2017-09-17_00_24_14-3438069670410854308 finished with status DONE. [INFO] Success result for Dataflow job 2017-09-17_00_24_14-3438069670410854308. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-09-17T07:27:13.334Z: (b259a276ef7e699e): Executing operation PAssert$315/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:27:13.353Z: (b259a276ef7e6673): Executing operation PAssert$315/GroupGlobally/GroupDummyAndContents/Read+PAssert$315/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$315/GroupGlobally/Values/Values/Map+PAssert$315/GroupGlobally/ParDo(Concat)+PAssert$315/GetPane/Map+PAssert$315/RunChecks+PAssert$315/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-09-17T07:27:12.917Z: (4743a015b03069c1): Executing operation PAssert$319/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:27:12.938Z: (4743a015b030670e): Executing operation PAssert$319/GroupGlobally/GroupDummyAndContents/Read+PAssert$319/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$319/GroupGlobally/Values/Values/Map+PAssert$319/GroupGlobally/ParDo(Concat)+PAssert$319/GetPane/Map+PAssert$319/RunChecks+PAssert$319/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-09-17T07:27:13.579Z: (b03841bd8caa66f6): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-09-17T07:27:13.621Z: (b03841bd8caa6e5e): Executing operation PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-09-17T07:27:13.691Z: (b03841bd8caa60e2): 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$320/GroupGlobally/Window.Into()/Window.Assign+PAssert$320/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$320/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$320/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-09-17T07:27:14.775Z: (2b6adca5d1ca53c5): Cleaning up. [INFO] 2017-09-17T07:27:14.780Z: (2b6adca5d1ca5dd1): Stopping worker pool... [INFO] 2017-09-17T07:27:23.350Z: (f568adb4c3488bd9): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-09-17T07:27:23.352Z: (f568adb4c3488d5b): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-09-17T07:27:23.385Z: (b03841bd8caa6e82): Executing operation PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-09-17T07:27:23.415Z: (b03841bd8caa65ea): Executing operation PAssert$320/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-09-17T07:27:23.491Z: (b03841bd8caa686e): Executing operation PAssert$320/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$320/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$320/GroupGlobally/GroupDummyAndContents/Reify+PAssert$320/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:27:23.504Z: (4743a015b03062c9): Executing operation PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$320/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$320/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$320/GroupGlobally/RewindowActuals/Window.Assign+PAssert$320/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$320/GroupGlobally/GroupDummyAndContents/Reify+PAssert$320/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-09-17T07:27:25.893Z: (4743a015b030698f): Executing operation PAssert$320/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-09-17T07:27:25.956Z: (4743a015b03066dc): Executing operation PAssert$320/GroupGlobally/GroupDummyAndContents/Read+PAssert$320/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$320/GroupGlobally/Values/Values/Map+PAssert$320/GroupGlobally/ParDo(Concat)+PAssert$320/GetPane/Map+PAssert$320/RunChecks+PAssert$320/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-09-17T07:27:26.764Z: (4d7f96c3819240d5): Cleaning up. [INFO] 2017-09-17T07:27:26.769Z: (4d7f96c3819242d9): Stopping worker pool... [INFO] 2017-09-17T07:27:29.567Z: (5157760f3f3612b6): Autoscaling: Resized worker pool from 2 to 0. [INFO] 2017-09-17T07:27:29.576Z: (5157760f3f3619fc): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-09-17_00_24_09-10717491055243151316 finished with status DONE. [INFO] Success result for Dataflow job 2017-09-17_00_24_09-10717491055243151316. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-09-17T07:27:34.602Z: (393330acf878c093): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-09-17T07:27:34.604Z: (393330acf878cd91): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-09-17_00_24_24-4690019057727820660 finished with status DONE. [INFO] Success result for Dataflow job 2017-09-17_00_24_24-4690019057727820660. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-09-17T07:27:38.487Z: (588cc22d44e94316): Autoscaling: Resized worker pool from 2 to 0. [INFO] 2017-09-17T07:27:38.489Z: (588cc22d44e94e18): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-09-17_00_24_22-9852094687420791041 finished with status DONE. [INFO] Success result for Dataflow job 2017-09-17_00_24_22-9852094687420791041. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-09-17T07:27:43.778Z: (5da2fab9bbbc7922): Autoscaling: Resized worker pool from 2 to 0. [INFO] 2017-09-17T07:27:43.781Z: (5da2fab9bbbc7268): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-09-17_00_24_48-15983265124330815880 finished with status DONE. [INFO] Success result for Dataflow job 2017-09-17_00_24_48-15983265124330815880. Found 2 success, 0 failures out of 2 expected assertions. [INFO] Job 2017-09-17_00_24_25-5192085517793693251 finished with status DONE. [INFO] Success result for Dataflow job 2017-09-17_00_24_25-5192085517793693251. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-09-17T07:28:04.881Z: (d238a64676ebd28e): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-09-17T07:28:04.883Z: (d238a64676ebda84): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-09-17T07:28:08.833Z: (76759b6b8f34fb11): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-09-17T07:28:08.835Z: (76759b6b8f34f2e7): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-09-17_00_24_17-17240519606441431409 finished with status DONE. [INFO] Success result for Dataflow job 2017-09-17_00_24_17-17240519606441431409. Found 3 success, 0 failures out of 3 expected assertions. [INFO] Job 2017-09-17_00_24_23-1850424274653866276 finished with status DONE. [INFO] Success result for Dataflow job 2017-09-17_00_24_23-1850424274653866276. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-09-17T07:28:30.174Z: (4a6ae86885bb7120): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-09-17T07:28:30.176Z: (4a6ae86885bb753a): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-09-17_00_24_18-3940679150621450337 finished with status DONE. [INFO] Success result for Dataflow job 2017-09-17_00_24_18-3940679150621450337. Found 3 success, 0 failures out of 3 expected assertions. 2017-09-17T07:28:39.035 [INFO] Running org.apache.beam.sdk.transforms.CombineTest 2017-09-17T07:28:39.429 [INFO] Tests run: 22, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 507.315 s - in org.apache.beam.sdk.transforms.CombineTest 2017-09-17T07:28:39.430 [INFO] Running org.apache.beam.sdk.values.PDoneTest 2017-09-17T07:28:39.436 [WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 s - in org.apache.beam.sdk.values.PDoneTest 2017-09-17T07:28:39.437 [INFO] Running org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest 2017-09-17T07:28:39.440 [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.472 s - in org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest 2017-09-17T07:28:39.444 [INFO] 2017-09-17T07:28:39.444 [INFO] Results: 2017-09-17T07:28:39.444 [INFO] 2017-09-17T07:28:39.444 [WARNING] Tests run: 258, Failures: 0, Errors: 0, Skipped: 1 2017-09-17T07:28:39.444 [INFO] [JENKINS] Recording test results 2017-09-17T07:28:40.426 [INFO] 2017-09-17T07:28:40.426 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-09-17T07:28:40.661 [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-09-17T07:28:53.482 [INFO] ------------------------------------------------------------------------ 2017-09-17T07:28:53.482 [INFO] Reactor Summary: 2017-09-17T07:28:53.482 [INFO] 2017-09-17T07:28:53.482 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 22.571 s] 2017-09-17T07:28:53.482 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 10.632 s] 2017-09-17T07:28:53.482 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.440 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Common ...................... SUCCESS [ 2.319 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Common :: Runner API ........ SUCCESS [ 15.426 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Common :: Fn API ............ SUCCESS [ 14.238 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 2.339 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [01:21 min] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 2.189 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [ 13.348 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [ 30.096 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [04:44 min] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 2.222 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 2.525 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [ 14.679 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 15.089 s] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [01:09 min] 2017-09-17T07:28:53.483 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:16 h] 2017-09-17T07:28:53.483 [INFO] ------------------------------------------------------------------------ 2017-09-17T07:28:53.483 [INFO] BUILD SUCCESS 2017-09-17T07:28:53.483 [INFO] ------------------------------------------------------------------------ 2017-09-17T07:28:53.483 [INFO] Total time: 01:27 h 2017-09-17T07:28:53.483 [INFO] Finished at: 2017-09-17T07:28:53+00:00 2017-09-17T07:28:54.879 [INFO] Final Memory: 350M/2462M 2017-09-17T07:28:54.879 [INFO] ------------------------------------------------------------------------ channel stopped
