See <https://builds.apache.org/job/beam_PostCommit_Java_RunnableOnService_Dataflow/2208/>
------------------------------------------ [...truncated 26076 lines...] [INFO] 2017-02-06T06:57:28.688Z: (2526ad5fb5c41518): Fusing consumer PAssert$266/GroupGlobally/RemoveActualsTriggering/Identity into PAssert$266/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-02-06T06:57:28.690Z: (2526ad5fb5c412fa): Fusing consumer PAssert$266/GroupGlobally/RewindowActuals into PAssert$266/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-02-06T06:57:28.692Z: (2526ad5fb5c410dc): Fusing consumer PAssert$266/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$266/GroupGlobally/Window.Into() [INFO] 2017-02-06T06:57:28.694Z: (2526ad5fb5c41ebe): Fusing consumer PAssert$266/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-02-06T06:57:28.697Z: (2526ad5fb5c41ca0): Fusing consumer Reshuffle/GroupByKey/Write into Reshuffle/GroupByKey/Reify [INFO] 2017-02-06T06:57:28.700Z: (2526ad5fb5c41a82): Fusing consumer PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-02-06T06:57:28.705Z: (2526ad5fb5c41864): Fusing consumer PAssert$266/GroupGlobally/Window.Into() into Reshuffle/ExpandIterable [INFO] 2017-02-06T06:57:28.707Z: (2526ad5fb5c41646): Fusing consumer PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$266/GroupGlobally/GatherAllOutputs/Window.Into() [INFO] 2017-02-06T06:57:28.710Z: (2526ad5fb5c41428): Fusing consumer Reshuffle/Window.Into() into Create.Values/Read(CreateSource) [INFO] 2017-02-06T06:57:28.715Z: (2526ad5fb5c4120a): Fusing consumer Reshuffle/GroupByKey/Reify into Reshuffle/Window.Into() [INFO] 2017-02-06T06:57:28.720Z: (2526ad5fb5c41fec): Fusing consumer PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-02-06T06:57:28.723Z: (2526ad5fb5c41dce): Fusing consumer Reshuffle/ExpandIterable into Reshuffle/GroupByKey/GroupByWindow [INFO] 2017-02-06T06:57:28.725Z: (2526ad5fb5c41bb0): Fusing consumer PAssert$266/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$266/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-02-06T06:57:28.727Z: (2526ad5fb5c41992): Fusing consumer PAssert$266/GroupGlobally/GatherAllOutputs/Window.Into() into PAssert$266/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-02-06T06:57:28.729Z: (2526ad5fb5c41774): Fusing consumer Reshuffle/GroupByKey/GroupByWindow into Reshuffle/GroupByKey/Read [INFO] 2017-02-06T06:57:28.731Z: (2526ad5fb5c41556): Fusing consumer PAssert$266/GroupGlobally/GroupDummyAndContents/Write into PAssert$266/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-02-06T06:57:28.734Z: (2526ad5fb5c41338): Fusing consumer PAssert$266/GroupGlobally/GroupDummyAndContents/Reify into PAssert$266/GroupGlobally/NeverTrigger/Identity [INFO] 2017-02-06T06:57:28.736Z: (2526ad5fb5c4111a): Fusing consumer PAssert$266/GroupGlobally/NeverTrigger/Identity into PAssert$266/GroupGlobally/RemoveDummyTriggering/Identity [INFO] 2017-02-06T06:57:28.739Z: (2526ad5fb5c41efc): Fusing consumer PAssert$266/GroupGlobally/WindowIntoDummy into PAssert$266/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-02-06T06:57:28.742Z: (2526ad5fb5c41cde): Fusing consumer PAssert$266/GroupGlobally/RemoveDummyTriggering/Identity into PAssert$266/GroupGlobally/WindowIntoDummy [INFO] 2017-02-06T06:57:28.885Z: (2526ad5fb5c41d98): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-02-06T06:57:29.396Z: S02: (2526ad5fb5c41b7a): Executing operation Create.Values/Read(CreateSource)+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-06T06:57:28.552Z: S03: (ee5e317269c22790): Executing operation PAssert$259/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:57:28.578Z: S04: (705611cdf06d6617): Executing operation PAssert$259/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:57:28.765Z: S05: (705611cdf06d65bf): Executing operation PAssert$259/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$259/GroupGlobally/WindowIntoDummy+PAssert$259/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$259/GroupGlobally/NeverTrigger/Identity+PAssert$259/GroupGlobally/GroupDummyAndContents/Reify+PAssert$259/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:57:28.767Z: S06: (acbb81d729b839a1): Executing operation PAssert$259/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$259/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$259/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$259/GroupGlobally/RewindowActuals+PAssert$259/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$259/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$259/GroupGlobally/NeverTrigger/Identity+PAssert$259/GroupGlobally/GroupDummyAndContents/Reify+PAssert$259/GroupGlobally/GroupDummyAndContents/Write [INFO] Job 2017-02-05_22_54_36-7043849718066321793 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_54_36-7043849718066321793. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-06T06:57:29.837Z: S07: (705611cdf06d6b46): Executing operation PAssert$259/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:57:29.864Z: S08: (f66a040b647ddae5): Executing operation PAssert$259/GroupGlobally/GroupDummyAndContents/Read+PAssert$259/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$259/GroupGlobally/Values/Values/Map+PAssert$259/GroupGlobally/ParDo(Concat)+PAssert$259/GetPane/Map+PAssert$259/RunChecks [INFO] 2017-02-06T06:57:30.776Z: (733928b7649b4d1a): Cleaning up. [INFO] 2017-02-06T06:57:30.886Z: (733928b7649b4356): Stopping worker pool... [INFO] 2017-02-06T06:57:32.753Z: S03: (bd91d337fdf1e673): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Close [INFO] 2017-02-06T06:57:32.788Z: S05: (1893fce8a10dda54): Executing operation PAssert$256/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-06T06:57:32.791Z: S04: (1824318b8cdb3c69): Executing operation View.AsSingleton/BatchViewAsSingleton/DataflowRunner.GroupByWindowHashAsKeyAndWindowAsSortKey/DataflowRunner.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-02-06T06:57:32.978Z: (117c47723ed136c6): Autoscaling: Attempting to upscale worker pool to 2. [INFO] 2017-02-06T06:57:33.016Z: S06: (4307999ddbd3c0fd): 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/DataflowRunner.BatchViewAsIterable/ParDo(ToIsmRecordForGlobalWindow)+View.AsSingleton/BatchViewAsSingleton/DataflowRunner.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/BatchViewAsSingleton/DataflowRunner.GroupByWindowHashAsKeyAndWindowAsSortKey/DataflowRunner.GroupByKeyAndSortValuesOnly/Write+PAssert$256/GroupGlobally/Window.Into()+PAssert$256/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$256/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$256/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$256/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$256/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:57:31.605Z: S16: (8ca554cb75bb080d): Executing operation Combine.globally(MeanInts)/View.AsIterable/DataflowRunner.BatchViewAsIterable/View.CreatePCollectionView [INFO] 2017-02-06T06:57:31.674Z: S17: (47f03756b1f1b780): Executing operation Combine.globally(MeanInts)/CreateVoid/Read(CreateSource)+Combine.globally(MeanInts)/ProduceDefault+PAssert$254/GroupGlobally/Window.Into()+PAssert$254/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$254/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$254/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$254/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$254/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:57:32.541Z: S18: (5a5e93fca735442a): Executing operation PAssert$254/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:57:32.566Z: S19: (f64d7858fd075837): Executing operation PAssert$254/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:57:32.758Z: S21: (20267e4e71024b1a): Executing operation PAssert$254/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$254/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$254/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$254/GroupGlobally/RewindowActuals+PAssert$254/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$254/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$254/GroupGlobally/NeverTrigger/Identity+PAssert$254/GroupGlobally/GroupDummyAndContents/Reify+PAssert$254/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:57:32.758Z: S20: (ef5aff35ba95789): Executing operation PAssert$254/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$254/GroupGlobally/WindowIntoDummy+PAssert$254/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$254/GroupGlobally/NeverTrigger/Identity+PAssert$254/GroupGlobally/GroupDummyAndContents/Reify+PAssert$254/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:57:33.727Z: S22: (dbecba6894737972): Executing operation PAssert$254/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:57:33.756Z: S23: (f8be2d7c61558863): Executing operation PAssert$254/GroupGlobally/GroupDummyAndContents/Read+PAssert$254/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$254/GroupGlobally/Values/Values/Map+PAssert$254/GroupGlobally/ParDo(Concat)+PAssert$254/GetPane/Map+PAssert$254/RunChecks [INFO] 2017-02-06T06:57:34.362Z: (ef5aff35ba95b5e): Cleaning up. [INFO] 2017-02-06T06:57:34.447Z: (ef5aff35ba959da): Stopping worker pool... [INFO] 2017-02-06T06:57:35.149Z: S07: (bd91d337fdf1e1fb): Executing operation Sum/View.AsIterable/DataflowRunner.BatchViewAsIterable/View.CreatePCollectionView [INFO] 2017-02-06T06:57:35.222Z: S08: (e6ecee080c5c4099): Executing operation Sum/CreateVoid/Read(CreateSource)+Sum/ProduceDefault+View.AsSingleton/BatchViewAsSingleton/DataflowRunner.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/BatchViewAsSingleton/DataflowRunner.GroupByWindowHashAsKeyAndWindowAsSortKey/DataflowRunner.GroupByKeyAndSortValuesOnly/Write+PAssert$256/GroupGlobally/Window.Into()+PAssert$256/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$256/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$256/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$256/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$256/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:57:36.211Z: S09: (24326ee72afc4380): Executing operation View.AsSingleton/BatchViewAsSingleton/DataflowRunner.GroupByWindowHashAsKeyAndWindowAsSortKey/DataflowRunner.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-02-06T06:57:36.213Z: S34: (ffda61093068c8ee): Executing operation PAssert$256/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:57:36.238Z: S10: (6155c1db90f2ea61): Executing operation View.AsSingleton/BatchViewAsSingleton/DataflowRunner.GroupByWindowHashAsKeyAndWindowAsSortKey/DataflowRunner.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/BatchViewAsSingleton/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-02-06T06:57:36.240Z: S35: (dbf90d9003cabea9): Executing operation PAssert$256/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:57:36.434Z: S37: (dbf90d9003cabf91): Executing operation PAssert$256/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$256/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$256/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$256/GroupGlobally/RewindowActuals+PAssert$256/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$256/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$256/GroupGlobally/NeverTrigger/Identity+PAssert$256/GroupGlobally/GroupDummyAndContents/Reify+PAssert$256/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:57:36.480Z: S36: (4307999ddbd3c576): Executing operation PAssert$256/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$256/GroupGlobally/WindowIntoDummy+PAssert$256/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$256/GroupGlobally/NeverTrigger/Identity+PAssert$256/GroupGlobally/GroupDummyAndContents/Reify+PAssert$256/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:57:39.019Z: S38: (e6ecee080c5c4c48): Executing operation PAssert$256/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:57:39.042Z: S39: (1824318b8cdb3441): Executing operation PAssert$256/GroupGlobally/GroupDummyAndContents/Read+PAssert$256/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$256/GroupGlobally/Values/Values/Map+PAssert$256/GroupGlobally/ParDo(Concat)+PAssert$256/GetPane/Map+PAssert$256/RunChecks [INFO] 2017-02-06T06:57:39.388Z: S23: (ce6720e83ffb677f): Executing operation Combine.perKey(TestKeyedCombineFnWithContext)/GroupByKey/Create [INFO] 2017-02-06T06:57:39.389Z: S12: (18b204a4cd547811): Executing operation Combine.globally(Anonymous)/Combine.perKey(Anonymous)/GroupByKey/Create [INFO] 2017-02-06T06:57:39.010Z: (5056e7f67bfa2e5d): Workers have started successfully. [INFO] 2017-02-06T06:57:39.704Z: S13: (ffda61093068cc16): Executing operation Combine.globally(Anonymous)/WithKeys/AddKeys/Map+Combine.globally(Anonymous)/Combine.perKey(Anonymous)/GroupByKey+Combine.globally(Anonymous)/Combine.perKey(Anonymous)/Combine.GroupedValues/Partial+Combine.globally(Anonymous)/Combine.perKey(Anonymous)/GroupByKey/Reify+Combine.globally(Anonymous)/Combine.perKey(Anonymous)/GroupByKey/Write [INFO] 2017-02-06T06:57:39.748Z: S24: (4307999ddbd3c5ed): Executing operation Combine.perKey(TestKeyedCombineFnWithContext)/GroupByKey+Combine.perKey(TestKeyedCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestKeyedCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestKeyedCombineFnWithContext)/GroupByKey/Write [INFO] 2017-02-06T06:57:40.840Z: S25: (c7e84813468ece6e): Executing operation Combine.perKey(TestKeyedCombineFnWithContext)/GroupByKey/Close [INFO] 2017-02-06T06:57:40.869Z: S26: (617d3f0c9ca99e01): Executing operation PAssert$257/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-06T06:57:41.057Z: S27: (1893fce8a10ddec2): Executing operation Combine.perKey(TestKeyedCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestKeyedCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestKeyedCombineFnWithContext)/Combine.GroupedValues/Extract+PAssert$257/GroupGlobally/Window.Into()+PAssert$257/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$257/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$257/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$257/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$257/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:57:41.194Z: S14: (99de08185c632993): Executing operation Combine.globally(Anonymous)/Combine.perKey(Anonymous)/GroupByKey/Close [INFO] 2017-02-06T06:57:41.228Z: S15: (dbf90d9003cab59b): Executing operation PAssert$258/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-06T06:57:41.413Z: S16: (1824318b8cdb36ec): Executing operation Combine.globally(Anonymous)/Combine.perKey(Anonymous)/GroupByKey/Read+Combine.globally(Anonymous)/Combine.perKey(Anonymous)/Combine.GroupedValues+Combine.globally(Anonymous)/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract+Combine.globally(Anonymous)/Values/Values/Map+PAssert$258/GroupGlobally/Window.Into()+PAssert$258/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$258/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$258/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$258/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$258/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:57:41.550Z: S28: (e6ecee080c5c4a81): Executing operation PAssert$257/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:57:41.576Z: S29: (6155c1db90f2e963): Executing operation PAssert$257/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:57:41.748Z: S30: (24326ee72afc4a1a): Executing operation PAssert$257/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$257/GroupGlobally/WindowIntoDummy+PAssert$257/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$257/GroupGlobally/NeverTrigger/Identity+PAssert$257/GroupGlobally/GroupDummyAndContents/Reify+PAssert$257/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:57:41.750Z: S31: (c7e84813468ec62f): Executing operation PAssert$257/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$257/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$257/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$257/GroupGlobally/RewindowActuals+PAssert$257/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$257/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$257/GroupGlobally/NeverTrigger/Identity+PAssert$257/GroupGlobally/GroupDummyAndContents/Reify+PAssert$257/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:57:41.904Z: S17: (bd91d337fdf1e75e): Executing operation PAssert$258/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:57:41.931Z: S18: (e6ecee080c5c48ba): Executing operation PAssert$258/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:57:42.004Z: S19: (a4cc3996baff9846): Executing operation PAssert$258/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$258/GroupGlobally/WindowIntoDummy+PAssert$258/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$258/GroupGlobally/NeverTrigger/Identity+PAssert$258/GroupGlobally/GroupDummyAndContents/Reify+PAssert$258/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:57:42.007Z: S20: (ce6720e83ffb6a89): Executing operation PAssert$258/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$258/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$258/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$258/GroupGlobally/RewindowActuals+PAssert$258/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$258/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$258/GroupGlobally/NeverTrigger/Identity+PAssert$258/GroupGlobally/GroupDummyAndContents/Reify+PAssert$258/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:57:42.297Z: S32: (1824318b8cdb3a60): Executing operation PAssert$257/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:57:42.327Z: S33: (99de08185c632efb): Executing operation PAssert$257/GroupGlobally/GroupDummyAndContents/Read+PAssert$257/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$257/GroupGlobally/Values/Values/Map+PAssert$257/GroupGlobally/ParDo(Concat)+PAssert$257/GetPane/Map+PAssert$257/RunChecks [INFO] 2017-02-06T06:57:42.599Z: S21: (6155c1db90f2eceb): Executing operation PAssert$258/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:57:42.630Z: S22: (4307999ddbd3c2b4): Executing operation PAssert$258/GroupGlobally/GroupDummyAndContents/Read+PAssert$258/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$258/GroupGlobally/Values/Values/Map+PAssert$258/GroupGlobally/ParDo(Concat)+PAssert$258/GetPane/Map+PAssert$258/RunChecks [INFO] 2017-02-06T06:57:43.152Z: (6155c1db90f2e0e4): Cleaning up. [INFO] 2017-02-06T06:57:43.157Z: (6155c1db90f2e2a8): Stopping worker pool... [INFO] 2017-02-06T06:57:50.106Z: (cb436b3811e88679): Workers have started successfully. [INFO] 2017-02-06T06:57:54.258Z: (3b135afb95feafe6): Worker pool stopped. [INFO] Job 2017-02-05_22_54_28-7508750257920369394 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_54_28-7508750257920369394. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-02-06T06:58:05.859Z: S03: (ccfa64ac560552d8): Executing operation GroupByKey/Close [INFO] 2017-02-06T06:58:05.884Z: S04: (1576a841775c542): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-06T06:58:06.057Z: S05: (ccfa64ac56055fa0): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-06T06:58:07.222Z: S06: (506cb95a5e0fafad): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-06T06:58:07.247Z: S07: (506cb95a5e0fabbc): Executing operation PAssert$261/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-06T06:58:07.437Z: S08: (2b144da68d696365): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$261/GroupGlobally/Window.Into()+PAssert$261/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$261/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$261/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$261/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$261/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:58:07.765Z: (24f68bcb5cd107ce): Workers have started successfully. [INFO] 2017-02-06T06:58:08.926Z: S09: (2b144da68d696e83): Executing operation PAssert$261/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:58:08.951Z: S10: (2b144da68d696664): Executing operation PAssert$261/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:58:09.144Z: S12: (58753d1ebe44fe1b): Executing operation PAssert$261/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$261/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$261/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$261/GroupGlobally/RewindowActuals+PAssert$261/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$261/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$261/GroupGlobally/NeverTrigger/Identity+PAssert$261/GroupGlobally/GroupDummyAndContents/Reify+PAssert$261/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:09.146Z: S11: (506cb95a5e0fa984): Executing operation PAssert$261/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$261/GroupGlobally/WindowIntoDummy+PAssert$261/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$261/GroupGlobally/NeverTrigger/Identity+PAssert$261/GroupGlobally/GroupDummyAndContents/Reify+PAssert$261/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:09.837Z: (d30114dc62d381e9): Workers have started successfully. [INFO] 2017-02-06T06:58:09.934Z: (f045c190e02c64e0): Workers have started successfully. [INFO] 2017-02-06T06:58:10.133Z: S13: (ccfa64ac56055bfb): Executing operation PAssert$261/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:58:10.161Z: S14: (c43f56d54f383c62): Executing operation PAssert$261/GroupGlobally/GroupDummyAndContents/Read+PAssert$261/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$261/GroupGlobally/Values/Values/Map+PAssert$261/GroupGlobally/ParDo(Concat)+PAssert$261/GetPane/Map+PAssert$261/RunChecks [INFO] 2017-02-06T06:58:11.004Z: (1576a841775c663): Cleaning up. [INFO] 2017-02-06T06:58:11.109Z: (1576a841775c47f): Stopping worker pool... [INFO] 2017-02-06T06:58:12.594Z: S03: (2f149cfc41d077c8): Executing operation PAssert$260/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:58:12.618Z: S04: (2c15e269e7b9e3fd): Executing operation PAssert$260/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:58:12.808Z: S05: (b7d2542c2d1829b5): Executing operation PAssert$260/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$260/GroupGlobally/WindowIntoDummy+PAssert$260/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$260/GroupGlobally/NeverTrigger/Identity+PAssert$260/GroupGlobally/GroupDummyAndContents/Reify+PAssert$260/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:12.811Z: S06: (34b6b9d0fa4ebad3): Executing operation PAssert$260/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$260/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$260/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$260/GroupGlobally/RewindowActuals+PAssert$260/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$260/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$260/GroupGlobally/NeverTrigger/Identity+PAssert$260/GroupGlobally/GroupDummyAndContents/Reify+PAssert$260/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:14.186Z: S07: (66905966b085b090): Executing operation PAssert$260/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:58:14.211Z: S08: (28b703b91c51a484): Executing operation PAssert$260/GroupGlobally/GroupDummyAndContents/Read+PAssert$260/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$260/GroupGlobally/Values/Values/Map+PAssert$260/GroupGlobally/ParDo(Concat)+PAssert$260/GetPane/Map+PAssert$260/RunChecks [INFO] 2017-02-06T06:58:14.833Z: (1078b51077b98238): Cleaning up. [INFO] 2017-02-06T06:58:14.942Z: (1078b51077b9860c): Stopping worker pool... [INFO] 2017-02-06T06:58:22.464Z: S03: (645627af4695b4f8): Executing operation GroupByKey/Close [INFO] 2017-02-06T06:58:22.490Z: S04: (63cffdf6cc34b1f9): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-06T06:58:22.689Z: S05: (645627af4695ba90): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-06T06:58:23.891Z: S07: (645627af4695bdd9): Executing operation PAssert$263/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-06T06:58:24.083Z: S08: (1ce3dee6e1535b4e): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$263/GroupGlobally/Window.Into()+PAssert$263/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$263/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$263/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$263/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$263/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:58:23.899Z: S03: (11cf1c2d6e0853cd): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-06T06:58:23.923Z: S04: (2c8c42bcf160e970): Executing operation PAssert$262/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-06T06:58:24.113Z: S05: (126bddf9fd6ada4): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$262/GroupGlobally/Window.Into()+PAssert$262/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$262/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$262/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$262/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$262/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:58:24.841Z: S03: (3977439aa9876a41): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-06T06:58:24.865Z: S04: (24192731068f06d3): Executing operation PAssert$264/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-06T06:58:25.056Z: S05: (e5ccc2110d2d0b1a): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$264/GroupGlobally/Window.Into()+PAssert$264/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$264/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$264/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$264/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$264/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:58:26.979Z: S06: (d3c15fb2610382a7): Executing operation PAssert$264/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:58:27.009Z: S07: (8c551dcd54de2e21): Executing operation PAssert$264/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:58:27.187Z: S09: (13b6bfcf08ab4be1): Executing operation PAssert$264/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$264/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$264/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$264/GroupGlobally/RewindowActuals+PAssert$264/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$264/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$264/GroupGlobally/NeverTrigger/Identity+PAssert$264/GroupGlobally/GroupDummyAndContents/Reify+PAssert$264/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:27.190Z: S08: (4517d03353514d7): Executing operation PAssert$264/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$264/GroupGlobally/WindowIntoDummy+PAssert$264/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$264/GroupGlobally/NeverTrigger/Identity+PAssert$264/GroupGlobally/GroupDummyAndContents/Reify+PAssert$264/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:25.636Z: S09: (c6e6c8a7ca9a3c56): Executing operation PAssert$263/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:58:25.663Z: S10: (79fee8c9902f566f): Executing operation PAssert$263/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:58:25.848Z: S11: (77946c4167ccd0b): Executing operation PAssert$263/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$263/GroupGlobally/WindowIntoDummy+PAssert$263/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$263/GroupGlobally/NeverTrigger/Identity+PAssert$263/GroupGlobally/GroupDummyAndContents/Reify+PAssert$263/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:25.853Z: S12: (f6df6e03e3190bb4): Executing operation PAssert$263/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$263/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$263/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$263/GroupGlobally/RewindowActuals+PAssert$263/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$263/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$263/GroupGlobally/NeverTrigger/Identity+PAssert$263/GroupGlobally/GroupDummyAndContents/Reify+PAssert$263/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:27.133Z: S13: (57e3c59ed928b5e7): Executing operation PAssert$263/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:58:27.166Z: S14: (1ce3dee6e1535b85): Executing operation PAssert$263/GroupGlobally/GroupDummyAndContents/Read+PAssert$263/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$263/GroupGlobally/Values/Values/Map+PAssert$263/GroupGlobally/ParDo(Concat)+PAssert$263/GetPane/Map+PAssert$263/RunChecks [INFO] 2017-02-06T06:58:26.773Z: S06: (d547afba254545b5): Executing operation PAssert$262/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:58:26.797Z: S07: (2926202626b5c678): Executing operation PAssert$262/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:58:26.989Z: S08: (642ee3a99c9eb192): Executing operation PAssert$262/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$262/GroupGlobally/WindowIntoDummy+PAssert$262/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$262/GroupGlobally/NeverTrigger/Identity+PAssert$262/GroupGlobally/GroupDummyAndContents/Reify+PAssert$262/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:26.992Z: S09: (b56c5d597e7d0c01): Executing operation PAssert$262/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$262/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$262/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$262/GroupGlobally/RewindowActuals+PAssert$262/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$262/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$262/GroupGlobally/NeverTrigger/Identity+PAssert$262/GroupGlobally/GroupDummyAndContents/Reify+PAssert$262/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:58:28.398Z: S10: (b4ab164bfab57050): Executing operation PAssert$262/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:58:28.423Z: S11: (642ee3a99c9eba96): Executing operation PAssert$262/GroupGlobally/GroupDummyAndContents/Read+PAssert$262/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$262/GroupGlobally/Values/Values/Map+PAssert$262/GroupGlobally/ParDo(Concat)+PAssert$262/GetPane/Map+PAssert$262/RunChecks [INFO] 2017-02-06T06:58:28.441Z: S10: (12104c8a95362b5): Executing operation PAssert$264/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:58:27.935Z: (c6e6c8a7ca9a37ac): Cleaning up. [INFO] 2017-02-06T06:58:28.010Z: (c6e6c8a7ca9a38a0): Stopping worker pool... [INFO] 2017-02-06T06:58:29.344Z: (9f6939f5b52fc42e): Cleaning up. [INFO] 2017-02-06T06:58:29.399Z: (9f6939f5b52fc502): Stopping worker pool... [INFO] 2017-02-06T06:58:29.283Z: (4b1dfd6d554091fd): Cleaning up. [INFO] 2017-02-06T06:58:29.394Z: (4b1dfd6d554098c1): Stopping worker pool... [INFO] 2017-02-06T06:58:41.915Z: (63be31de6b566d88): Worker pool stopped. [INFO] 2017-02-06T06:58:45.894Z: (733928b7649b4003): Worker pool stopped. [INFO] Job 2017-02-05_22_56_00-6030842688582866565 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_56_00-6030842688582866565. Found 2 success, 0 failures out of 2 expected assertions. [INFO] Job 2017-02-05_22_56_12-17391009115008076817 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_56_12-17391009115008076817. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-06T06:58:53.785Z: (524159fb65dda24b): Workers have started successfully. [INFO] 2017-02-06T06:58:56.450Z: (d1b8601de83ac5cd): Workers have started successfully. [INFO] 2017-02-06T06:59:04.367Z: S03: (3e863dea2ba3b6ff): Executing operation GroupByKey/Close [INFO] 2017-02-06T06:59:04.395Z: S04: (d93f9ff73db73c41): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-06T06:59:04.581Z: S05: (3979b9271223dac5): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-06T06:59:05.549Z: S06: (ab79c759e893e6c4): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-06T06:59:05.574Z: S07: (d93f9ff73db73112): Executing operation PAssert$265/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-06T06:59:05.764Z: S08: (3979b9271223d293): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$265/GroupGlobally/Window.Into()+PAssert$265/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$265/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$265/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$265/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$265/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:59:05.969Z: S03: (469e84379957f954): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-06T06:59:06.000Z: S04: (aafdf932dbda6027): Executing operation PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-06T06:59:06.221Z: S05: (184e2945159a64cf): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$266/GroupGlobally/Window.Into()+PAssert$266/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$266/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$266/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-06T06:59:07.296Z: S09: (ab79c759e893e8fe): Executing operation PAssert$265/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:59:07.321Z: S10: (b776b1998e26c2f7): Executing operation PAssert$265/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:59:07.515Z: S11: (3979b9271223da61): Executing operation PAssert$265/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$265/GroupGlobally/WindowIntoDummy+PAssert$265/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$265/GroupGlobally/NeverTrigger/Identity+PAssert$265/GroupGlobally/GroupDummyAndContents/Reify+PAssert$265/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:59:07.518Z: S12: (52a5ccad45107093): Executing operation PAssert$265/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$265/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$265/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$265/GroupGlobally/RewindowActuals+PAssert$265/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$265/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$265/GroupGlobally/NeverTrigger/Identity+PAssert$265/GroupGlobally/GroupDummyAndContents/Reify+PAssert$265/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:59:08.404Z: S06: (469e84379957fbfb): Executing operation PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-06T06:59:08.449Z: S07: (c99dd60e62615242): Executing operation PAssert$266/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-06T06:59:08.624Z: S08: (699c5a801a89fc3a): Executing operation PAssert$266/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$266/GroupGlobally/WindowIntoDummy+PAssert$266/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$266/GroupGlobally/NeverTrigger/Identity+PAssert$266/GroupGlobally/GroupDummyAndContents/Reify+PAssert$266/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:59:08.625Z: S09: (b6aa7af4f217d43e): Executing operation PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$266/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$266/GroupGlobally/RewindowActuals+PAssert$266/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$266/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$266/GroupGlobally/NeverTrigger/Identity+PAssert$266/GroupGlobally/GroupDummyAndContents/Reify+PAssert$266/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-06T06:59:08.706Z: S13: (f385cc16f17936b2): Executing operation PAssert$265/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:59:08.732Z: S14: (35297b8f80fb9a26): Executing operation PAssert$265/GroupGlobally/GroupDummyAndContents/Read+PAssert$265/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$265/GroupGlobally/Values/Values/Map+PAssert$265/GroupGlobally/ParDo(Concat)+PAssert$265/GetPane/Map+PAssert$265/RunChecks [INFO] 2017-02-06T06:59:09.512Z: (9640432e0ed9272d): Cleaning up. [INFO] 2017-02-06T06:59:09.619Z: (9640432e0ed923f9): Stopping worker pool... [INFO] 2017-02-06T06:59:09.793Z: S10: (b791bfb4508580d2): Executing operation PAssert$266/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-06T06:59:09.822Z: S11: (c99dd60e626159ca): Executing operation PAssert$266/GroupGlobally/GroupDummyAndContents/Read+PAssert$266/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$266/GroupGlobally/Values/Values/Map+PAssert$266/GroupGlobally/ParDo(Concat)+PAssert$266/GetPane/Map+PAssert$266/RunChecks [INFO] 2017-02-06T06:59:11.097Z: (d77467e31eff6ccb): Cleaning up. [INFO] 2017-02-06T06:59:11.103Z: (d77467e31eff6d8f): Stopping worker pool... [INFO] 2017-02-06T06:59:14.455Z: (ef5aff35ba950b7): Worker pool stopped. [INFO] Job 2017-02-05_22_56_09-4490626298829466693 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_56_09-4490626298829466693. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-02-06T06:59:31.117Z: (1576a841775cf14): Worker pool stopped. [INFO] 2017-02-06T06:59:34.950Z: (1078b51077b984eb): Worker pool stopped. [INFO] Job 2017-02-05_22_56_46-1857145038401922109 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_56_46-1857145038401922109. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-02-05_22_56_30-6343526531595150318 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_56_30-6343526531595150318. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-06T06:59:43.037Z: (c6e6c8a7ca9a3d57): Worker pool stopped. [INFO] 2017-02-06T06:59:44.407Z: (9f6939f5b52fc9a1): Worker pool stopped. [INFO] Job 2017-02-05_22_56_57-8280163571166828152 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_56_57-8280163571166828152. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-02-05_22_57_05-3872704626090151667 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_57_05-3872704626090151667. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-06T06:59:49.401Z: (4b1dfd6d554099d4): Worker pool stopped. [INFO] Job 2017-02-05_22_56_55-9487623870291949879 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_56_55-9487623870291949879. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-06T07:00:29.627Z: (9640432e0ed92992): Worker pool stopped. [INFO] 2017-02-06T07:00:31.110Z: (d77467e31eff6e22): Worker pool stopped. [INFO] Job 2017-02-05_22_57_23-17721177197064159658 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_57_23-17721177197064159658. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-02-05_22_57_23-1099721924921661299 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_57_23-1099721924921661299. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-06T07:00:48.169Z: (6155c1db90f2e3fb): Worker pool stopped. [INFO] Job 2017-02-05_22_56_12-11600201691208733333 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-05_22_56_12-11600201691208733333. Found 3 success, 0 failures out of 3 expected assertions. Running org.apache.beam.sdk.transforms.CombineTest Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 560.013 sec - in org.apache.beam.sdk.transforms.CombineTest Running org.apache.beam.sdk.values.PDoneTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0.004 sec - in org.apache.beam.sdk.values.PDoneTest Running org.apache.beam.sdk.transforms.KvSwapTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 210.39 sec - in org.apache.beam.sdk.transforms.KvSwapTest Running org.apache.beam.sdk.util.ReshuffleTest Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 233.129 sec - in org.apache.beam.sdk.util.ReshuffleTest Results : Tests run: 187, Failures: 0, Errors: 0, Skipped: 3 [JENKINS] Recording test results 2017-02-06T07:00:57.285 [INFO] 2017-02-06T07:00:57.285 [INFO] --- maven-dependency-plugin:2.10:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-02-06T07:00:57.368 [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 2017-02-06T07:01:00.074 [INFO] ------------------------------------------------------------------------ 2017-02-06T07:01:00.074 [INFO] Reactor Summary: 2017-02-06T07:01:00.074 [INFO] 2017-02-06T07:01:00.074 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 21.875 s] 2017-02-06T07:01:00.074 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 7.221 s] 2017-02-06T07:01:00.074 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 12.143 s] 2017-02-06T07:01:00.074 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 1.568 s] 2017-02-06T07:01:00.074 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [02:22 min] 2017-02-06T07:01:00.074 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 1.289 s] 2017-02-06T07:01:00.074 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [56:04 min] 2017-02-06T07:01:00.074 [INFO] ------------------------------------------------------------------------ 2017-02-06T07:01:00.074 [INFO] BUILD SUCCESS 2017-02-06T07:01:00.074 [INFO] ------------------------------------------------------------------------ 2017-02-06T07:01:00.075 [INFO] Total time: 59:54 min 2017-02-06T07:01:00.075 [INFO] Finished at: 2017-02-06T07:01:00+00:00 2017-02-06T07:01:01.161 [INFO] Final Memory: 256M/1908M 2017-02-06T07:01:01.161 [INFO] ------------------------------------------------------------------------ Waiting for Jenkins to finish collecting data channel stopped
