See <https://builds.apache.org/job/beam_PostCommit_Java_RunnableOnService_Dataflow/2445/display/redirect>
------------------------------------------ [...truncated 3.87 MB...] [INFO] 2017-03-02T07:35:47.270Z: (715e168a75870ca2): Fusing consumer PAssert$280/RunChecks into PAssert$280/GetPane/Map [INFO] 2017-03-02T07:35:47.276Z: (715e168a75870338): Unzipping flatten s18 for input s13.13 [INFO] 2017-03-02T07:35:47.279Z: (715e168a7587056a): Fusing unzipped copy of PAssert$280/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$280/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-03-02T07:35:47.281Z: (715e168a7587079c): Fusing consumer PAssert$280/GroupGlobally/GroupDummyAndContents/Reify into PAssert$280/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-03-02T07:35:47.289Z: (715e168a75870064): Unzipping flatten s18-u40 for input s20-reify-value19-c38 [INFO] 2017-03-02T07:35:47.291Z: (715e168a75870296): Fusing unzipped copy of PAssert$280/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$280/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-03-02T07:35:47.293Z: (715e168a758704c8): Fusing consumer PAssert$280/GroupGlobally/GroupDummyAndContents/Write into PAssert$280/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-03-02T07:35:47.295Z: (715e168a758706fa): Fusing consumer PAssert$280/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$280/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-03-02T07:35:47.297Z: (715e168a7587092c): Fusing consumer PAssert$280/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-03-02T07:35:47.299Z: (715e168a75870b5e): Fusing consumer Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract into Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues [INFO] 2017-03-02T07:35:47.302Z: (715e168a75870d90): Fusing consumer Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues into Distinct/Combine.perKey(Anonymous)/GroupByKey/Read [INFO] 2017-03-02T07:35:47.304Z: (715e168a75870fc2): Fusing consumer PAssert$280/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$280/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-03-02T07:35:47.306Z: (715e168a758701f4): Fusing consumer PAssert$280/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$280/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-03-02T07:35:47.308Z: (715e168a75870426): Fusing consumer PAssert$280/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$280/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-03-02T07:35:47.310Z: (715e168a75870658): Fusing consumer Distinct/Keys/Keys/Map into Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract [INFO] 2017-03-02T07:35:47.312Z: (715e168a7587088a): Fusing consumer PAssert$280/GroupGlobally/RewindowActuals/Window.Assign into PAssert$280/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-03-02T07:35:47.314Z: (715e168a75870abc): Fusing consumer PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-03-02T07:35:47.316Z: (715e168a75870cee): Fusing consumer Distinct/Combine.perKey(Anonymous)/GroupByKey/Reify into Distinct/Combine.perKey(Anonymous)/GroupByKey+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Partial [INFO] 2017-03-02T07:35:47.318Z: (715e168a75870f20): Fusing consumer Distinct/CreateIndex/Map into Create.Values/Read(CreateSource) [INFO] 2017-03-02T07:35:47.320Z: (715e168a75870152): Fusing consumer Distinct/Combine.perKey(Anonymous)/GroupByKey/Write into Distinct/Combine.perKey(Anonymous)/GroupByKey/Reify [INFO] 2017-03-02T07:35:47.322Z: (715e168a75870384): Fusing consumer PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-03-02T07:35:47.325Z: (715e168a758705b6): Fusing consumer PAssert$280/GroupGlobally/Window.Into()/Window.Assign into Distinct/Keys/Keys/Map [INFO] 2017-03-02T07:35:47.327Z: (715e168a758707e8): Fusing consumer PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$280/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-03-02T07:35:47.332Z: (715e168a75870a1a): Fusing consumer PAssert$280/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$280/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-03-02T07:35:47.334Z: (715e168a75870c4c): Fusing consumer Distinct/Combine.perKey(Anonymous)/GroupByKey+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Partial into Distinct/CreateIndex/Map [INFO] 2017-03-02T07:35:47.471Z: S01: (2e98163713366cd9): Executing operation Distinct/Combine.perKey(Anonymous)/GroupByKey/Create [INFO] 2017-03-02T07:35:47.677Z: (af143fd80179dc71): Starting 1 workers... [INFO] 2017-03-02T07:35:47.697Z: S02: (2e981637133667c2): Executing operation Create.Values/Read(CreateSource)+Distinct/CreateIndex/Map+Distinct/Combine.perKey(Anonymous)/GroupByKey+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Partial+Distinct/Combine.perKey(Anonymous)/GroupByKey/Reify+Distinct/Combine.perKey(Anonymous)/GroupByKey/Write [INFO] 2017-03-02T07:35:49.312Z: (22f7f3e2a5e3a794): Workers have started successfully. [INFO] 2017-03-02T07:35:52.351Z: (f5f62e756af6ee13): Checking required Cloud APIs are enabled. [INFO] 2017-03-02T07:35:52.868Z: (f5f62e756af6e398): Elided trivial flatten [INFO] 2017-03-02T07:35:52.870Z: (f5f62e756af6e0aa): Elided trivial flatten [INFO] 2017-03-02T07:35:52.872Z: (f5f62e756af6edbc): Elided trivial flatten [INFO] 2017-03-02T07:35:52.879Z: (f5f62e756af6e4f2): Unzipping flatten s18 for input s13.13 [INFO] 2017-03-02T07:35:52.882Z: (f5f62e756af6e204): Fusing unzipped copy of PAssert$281/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$281/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-03-02T07:35:52.884Z: (f5f62e756af6ef16): Fusing consumer PAssert$281/GroupGlobally/Values/Values/Map into PAssert$281/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-03-02T07:35:52.886Z: (f5f62e756af6ec28): Fusing consumer PAssert$281/GroupGlobally/ParDo(Concat) into PAssert$281/GroupGlobally/Values/Values/Map [INFO] 2017-03-02T07:35:52.893Z: (f5f62e756af6e35e): Unzipping flatten s18-u40 for input s20-reify-value19-c38 [INFO] 2017-03-02T07:35:52.896Z: (f5f62e756af6e070): Fusing unzipped copy of PAssert$281/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$281/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-03-02T07:35:52.898Z: (f5f62e756af6ed82): Fusing consumer PAssert$281/GetPane/Map into PAssert$281/GroupGlobally/ParDo(Concat) [INFO] 2017-03-02T07:35:52.901Z: (f5f62e756af6ea94): Fusing consumer PAssert$281/RunChecks into PAssert$281/GetPane/Map [INFO] 2017-03-02T07:35:52.903Z: (f5f62e756af6e7a6): Fusing consumer PAssert$281/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$281/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-03-02T07:35:52.906Z: (f5f62e756af6e4b8): Fusing consumer Distinct/Keys/Keys/Map into Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract [INFO] 2017-03-02T07:35:52.909Z: (f5f62e756af6e1ca): Fusing consumer PAssert$281/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-03-02T07:35:52.911Z: (f5f62e756af6eedc): Fusing consumer PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-03-02T07:35:52.914Z: (f5f62e756af6ebee): Fusing consumer Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract into Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues [INFO] 2017-03-02T07:35:52.916Z: (f5f62e756af6e900): Fusing consumer PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$281/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-03-02T07:35:52.918Z: (f5f62e756af6e612): Fusing consumer PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-03-02T07:35:52.921Z: (f5f62e756af6e324): Fusing consumer Distinct/Combine.perKey(Anonymous)/GroupByKey/Reify into Distinct/Combine.perKey(Anonymous)/GroupByKey+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Partial [INFO] 2017-03-02T07:35:52.923Z: (f5f62e756af6e036): Fusing consumer PAssert$281/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$281/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-03-02T07:35:52.925Z: (f5f62e756af6ed48): Fusing consumer PAssert$281/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$281/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-03-02T07:35:52.927Z: (f5f62e756af6ea5a): Fusing consumer PAssert$281/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$281/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-03-02T07:35:52.929Z: (f5f62e756af6e76c): Fusing consumer PAssert$281/GroupGlobally/RewindowActuals/Window.Assign into PAssert$281/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-03-02T07:35:52.931Z: (f5f62e756af6e47e): Fusing consumer Distinct/CreateIndex/Map into Create.Values/Read(CreateSource) [INFO] 2017-03-02T07:35:52.934Z: (f5f62e756af6e190): Fusing consumer Distinct/Combine.perKey(Anonymous)/GroupByKey+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Partial into Distinct/CreateIndex/Map [INFO] 2017-03-02T07:35:52.936Z: (f5f62e756af6eea2): Fusing consumer Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues into Distinct/Combine.perKey(Anonymous)/GroupByKey/Read [INFO] 2017-03-02T07:35:52.938Z: (f5f62e756af6ebb4): Fusing consumer Distinct/Combine.perKey(Anonymous)/GroupByKey/Write into Distinct/Combine.perKey(Anonymous)/GroupByKey/Reify [INFO] 2017-03-02T07:35:52.940Z: (f5f62e756af6e8c6): Fusing consumer PAssert$281/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$281/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-03-02T07:35:52.943Z: (f5f62e756af6e5d8): Fusing consumer PAssert$281/GroupGlobally/Window.Into()/Window.Assign into Distinct/Keys/Keys/Map [INFO] 2017-03-02T07:35:52.945Z: (f5f62e756af6e2ea): Fusing consumer PAssert$281/GroupGlobally/GroupDummyAndContents/Write into PAssert$281/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-03-02T07:35:52.947Z: (f5f62e756af6effc): Fusing consumer PAssert$281/GroupGlobally/GroupDummyAndContents/Reify into PAssert$281/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-03-02T07:35:52.949Z: (f5f62e756af6ed0e): Fusing consumer PAssert$281/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$281/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-03-02T07:35:53.096Z: S01: (f70bb21abd5e5c0e): Executing operation Distinct/Combine.perKey(Anonymous)/GroupByKey/Create [INFO] 2017-03-02T07:35:53.302Z: (3441462f683cb023): Starting 1 workers... [INFO] 2017-03-02T07:35:53.329Z: S02: (f70bb21abd5e5731): Executing operation Create.Values/Read(CreateSource)+Distinct/CreateIndex/Map+Distinct/Combine.perKey(Anonymous)/GroupByKey+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Partial+Distinct/Combine.perKey(Anonymous)/GroupByKey/Reify+Distinct/Combine.perKey(Anonymous)/GroupByKey/Write [INFO] 2017-03-02T07:35:58.431Z: (91fac103eae1f8ba): Workers have started successfully. [INFO] 2017-03-02T07:36:13.461Z: (92f77f491475fff7): Workers have started successfully. [INFO] 2017-03-02T07:36:13.517Z: (489731e902391106): Workers have started successfully. [INFO] 2017-03-02T07:36:18.550Z: (ec37553618e4ce34): Cleaning up. [INFO] 2017-03-02T07:36:18.555Z: (ec37553618e4c8d0): Stopping worker pool... [INFO] 2017-03-02T07:36:21.063Z: (fee1180501447419): Workers have started successfully. [INFO] 2017-03-02T07:36:21.079Z: (f351c054b5c60f5): Workers have started successfully. [INFO] 2017-03-02T07:36:34.275Z: (1fc71a9fa3f713b4): Cleaning up. [INFO] 2017-03-02T07:36:34.405Z: (1fc71a9fa3f71158): Stopping worker pool... [INFO] 2017-03-02T07:36:36.196Z: S03: (23ddee7825c27874): Executing operation GroupByKey/Close [INFO] 2017-03-02T07:36:36.216Z: S04: (23ddee7825c2761c): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+ParDo(Anonymous) [INFO] 2017-03-02T07:36:41.724Z: S06: (ca8107d9198457c1): Executing operation PAssert$274/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-03-02T07:36:41.727Z: S18: (9c65115f96f00d5f): Executing operation PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-03-02T07:36:41.730Z: S12: (3e8fb06bc9f460b4): Executing operation PAssert$273/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-03-02T07:36:41.733Z: S24: (16720dcf9c812ef0): Executing operation PAssert$275/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-03-02T07:36:41.746Z: S07: (9c65115f96f00fb2): Executing operation PAssert$274/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-03-02T07:36:41.750Z: S19: (3e8fb06bc9f46aef): Executing operation PAssert$276/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-03-02T07:36:41.754Z: S13: (16720dcf9c81295b): Executing operation PAssert$273/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-03-02T07:36:41.758Z: S25: (ca8107d919845bb8): Executing operation PAssert$275/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-03-02T07:36:41.941Z: S14: (3e8fb06bc9f4675a): Executing operation PAssert$273/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$273/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$273/GroupGlobally/GroupDummyAndContents/Reify+PAssert$273/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:36:41.946Z: S15: (ca8107d919845f9f): Executing operation PAssert$273/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$273/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$273/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$273/GroupGlobally/RewindowActuals/Window.Assign+PAssert$273/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$273/GroupGlobally/GroupDummyAndContents/Reify+PAssert$273/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:36:41.950Z: S08: (9c65115f96f00205): Executing operation PAssert$274/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$274/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$274/GroupGlobally/GroupDummyAndContents/Reify+PAssert$274/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:36:41.955Z: S09: (16720dcf9c8123c6): Executing operation PAssert$274/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$274/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$274/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$274/GroupGlobally/RewindowActuals/Window.Assign+PAssert$274/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$274/GroupGlobally/GroupDummyAndContents/Reify+PAssert$274/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:36:41.958Z: S26: (444c4d10f7555989): Executing operation PAssert$275/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$275/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$275/GroupGlobally/GroupDummyAndContents/Reify+PAssert$275/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:36:41.963Z: S27: (13a069e344065703): Executing operation PAssert$275/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$275/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$275/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$275/GroupGlobally/RewindowActuals/Window.Assign+PAssert$275/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$275/GroupGlobally/GroupDummyAndContents/Reify+PAssert$275/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:36:41.966Z: S20: (1a6eb54942d88d84): Executing operation PAssert$276/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$276/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$276/GroupGlobally/GroupDummyAndContents/Reify+PAssert$276/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:36:41.969Z: S21: (24117934b2739f33): Executing operation PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$276/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$276/GroupGlobally/RewindowActuals/Window.Assign+PAssert$276/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$276/GroupGlobally/GroupDummyAndContents/Reify+PAssert$276/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:36:42.859Z: (7d6d5a2245bca57c): Cleaning up. [INFO] 2017-03-02T07:36:42.986Z: (7d6d5a2245bcafc8): Stopping worker pool... [INFO] 2017-03-02T07:36:46.666Z: (e1028612ffba8565): Cleaning up. [INFO] 2017-03-02T07:36:46.800Z: (e1028612ffba8e61): Stopping worker pool... [INFO] 2017-03-02T07:36:48.167Z: (df0a5f77c69a4a0f): Cleaning up. [INFO] 2017-03-02T07:36:48.301Z: (df0a5f77c69a4db3): Stopping worker pool... [INFO] 2017-03-02T07:36:48.729Z: (b23e5fa99b37d7af): Workers have started successfully. [INFO] 2017-03-02T07:37:04.273Z: S03: (f3d8e7336d541366): Executing operation GroupByKey/Close [INFO] 2017-03-02T07:37:04.298Z: S04: (f3d8e7336d54163e): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+ParDo(Anonymous) [INFO] 2017-03-02T07:37:03.429Z: (9826659c1755d5f): Workers have started successfully. [INFO] 2017-03-02T07:37:10.833Z: (8b67faa05b95298): Cleaning up. [INFO] 2017-03-02T07:37:10.962Z: (8b67faa05b95b54): Stopping worker pool... [INFO] 2017-03-02T07:37:13.736Z: S22: (24117934b2739d85): Executing operation PAssert$276/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-03-02T07:37:13.759Z: S23: (24117934b2739e8d): Executing operation PAssert$276/GroupGlobally/GroupDummyAndContents/Read+PAssert$276/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$276/GroupGlobally/Values/Values/Map+PAssert$276/GroupGlobally/ParDo(Concat)+PAssert$276/GetPane/Map+PAssert$276/RunChecks [INFO] 2017-03-02T07:37:13.203Z: (32cfd25c39578c13): Workers have started successfully. [INFO] 2017-03-02T07:37:22.424Z: S28: (13a069e34406557d): Executing operation PAssert$275/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-03-02T07:37:22.452Z: S29: (13a069e344065a25): Executing operation PAssert$275/GroupGlobally/GroupDummyAndContents/Read+PAssert$275/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$275/GroupGlobally/Values/Values/Map+PAssert$275/GroupGlobally/ParDo(Concat)+PAssert$275/GetPane/Map+PAssert$275/RunChecks [INFO] 2017-03-02T07:37:23.484Z: S10: (9c65115f96f00fc9): Executing operation PAssert$274/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-03-02T07:37:23.517Z: S11: (9c65115f96f003a1): Executing operation PAssert$274/GroupGlobally/GroupDummyAndContents/Read+PAssert$274/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$274/GroupGlobally/Values/Values/Map+PAssert$274/GroupGlobally/ParDo(Concat)+PAssert$274/GetPane/Map+PAssert$274/RunChecks [INFO] 2017-03-02T07:37:23.563Z: (ec37553618e4ccc5): Worker pool stopped. [INFO] Job 2017-03-01_23_33_47-4371775023574648111 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_33_47-4371775023574648111. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-03-02T07:37:30.334Z: S03: (a0dd6cd4515023a4): Executing operation Distinct.WithRepresentativeValues/Combine.perKey(Anonymous)/GroupByKey/Close [INFO] 2017-03-02T07:37:30.355Z: S04: (a0dd6cd451502277): Executing operation PAssert$279/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-03-02T07:37:30.547Z: S05: (a0dd6cd451502922): Executing operation Distinct.WithRepresentativeValues/Combine.perKey(Anonymous)/GroupByKey/Read+Distinct.WithRepresentativeValues/Combine.perKey(Anonymous)/Combine.GroupedValues+Distinct.WithRepresentativeValues/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract+Distinct.WithRepresentativeValues/Values/Values/Map+PAssert$279/GroupGlobally/Window.Into()/Window.Assign+PAssert$279/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$279/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$279/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$279/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$279/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-03-02T07:37:32.677Z: (e1a1ea194a4d369a): Workers have started successfully. [INFO] 2017-03-02T07:37:32.999Z: S16: (ca8107d91984578d): Executing operation PAssert$273/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-03-02T07:37:33.020Z: S17: (ca8107d919845785): Executing operation PAssert$273/GroupGlobally/GroupDummyAndContents/Read+PAssert$273/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$273/GroupGlobally/Values/Values/Map+PAssert$273/GroupGlobally/ParDo(Concat)+PAssert$273/GetPane/Map+PAssert$273/RunChecks [INFO] 2017-03-02T07:37:34.412Z: (1fc71a9fa3f71b93): Worker pool stopped. [INFO] 2017-03-02T07:37:37.256Z: S06: (a0dd6cd4515026c8): Executing operation PAssert$279/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-03-02T07:37:37.278Z: S07: (a0dd6cd45150259b): Executing operation PAssert$279/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-03-02T07:37:37.465Z: S08: (a0dd6cd451502c46): Executing operation PAssert$279/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$279/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$279/GroupGlobally/GroupDummyAndContents/Reify+PAssert$279/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:37:37.470Z: S09: (c72384389e8507ed): Executing operation PAssert$279/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$279/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$279/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$279/GroupGlobally/RewindowActuals/Window.Assign+PAssert$279/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$279/GroupGlobally/GroupDummyAndContents/Reify+PAssert$279/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:37:39.345Z: (429faddacc17c552): Cleaning up. [INFO] Job 2017-03-01_23_34_02-11577882808151490512 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_34_02-11577882808151490512. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-03-02T07:37:39.440Z: (429faddacc17c6a6): Stopping worker pool... [INFO] 2017-03-02T07:37:42.784Z: S04: (6bb87be162622f18): Executing operation PAssert$278/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-03-02T07:37:42.786Z: S10: (6f4ab77687e479ba): Executing operation PAssert$277/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-03-02T07:37:42.805Z: S05: (6f4ab77687e4759d): Executing operation PAssert$278/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-03-02T07:37:42.807Z: S11: (6bb87be162622879): Executing operation PAssert$277/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-03-02T07:37:42.994Z: S12: (6bb87be1626226a2): Executing operation PAssert$277/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$277/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$277/GroupGlobally/GroupDummyAndContents/Reify+PAssert$277/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:37:42.999Z: S13: (6f4ab77687e47dd8): Executing operation PAssert$277/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$277/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$277/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$277/GroupGlobally/RewindowActuals/Window.Assign+PAssert$277/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$277/GroupGlobally/GroupDummyAndContents/Reify+PAssert$277/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:37:43.003Z: S06: (bbaae5853ac8a75e): Executing operation PAssert$278/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$278/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$278/GroupGlobally/GroupDummyAndContents/Reify+PAssert$278/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:37:43.008Z: S07: (cffa0c4b0f7ec942): Executing operation PAssert$278/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$278/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$278/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$278/GroupGlobally/RewindowActuals/Window.Assign+PAssert$278/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$278/GroupGlobally/GroupDummyAndContents/Reify+PAssert$278/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:37:46.596Z: (5e86f95158ee5eca): Workers have started successfully. [INFO] 2017-03-02T07:37:47.062Z: S10: (c72384389e850c73): Executing operation PAssert$279/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-03-02T07:37:47.087Z: S11: (c72384389e8503cb): Executing operation PAssert$279/GroupGlobally/GroupDummyAndContents/Read+PAssert$279/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$279/GroupGlobally/Values/Values/Map+PAssert$279/GroupGlobally/ParDo(Concat)+PAssert$279/GetPane/Map+PAssert$279/RunChecks [INFO] 2017-03-02T07:37:52.994Z: (7d6d5a2245bcaf81): Worker pool stopped. [INFO] 2017-03-02T07:37:53.137Z: S03: (2e981637133667ee): Executing operation Distinct/Combine.perKey(Anonymous)/GroupByKey/Close [INFO] 2017-03-02T07:37:53.154Z: S04: (2e9816371336680f): Executing operation PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-03-02T07:37:53.346Z: S05: (2e981637133662f8): Executing operation Distinct/Combine.perKey(Anonymous)/GroupByKey/Read+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract+Distinct/Keys/Keys/Map+PAssert$280/GroupGlobally/Window.Into()/Window.Assign+PAssert$280/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$280/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$280/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-03-02T07:37:53.545Z: (3d4b1de5c378b770): Cleaning up. [INFO] 2017-03-02T07:37:53.657Z: (3d4b1de5c378bc3c): Stopping worker pool... [INFO] 2017-03-02T07:37:55.642Z: S07: (2e9816371336635b): Executing operation PAssert$280/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-03-02T07:37:55.831Z: S08: (2e98163713366e44): Executing operation PAssert$280/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$280/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$280/GroupGlobally/GroupDummyAndContents/Reify+PAssert$280/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:37:55.836Z: S09: (4001c62e4814a6e5): Executing operation PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$280/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$280/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$280/GroupGlobally/RewindowActuals/Window.Assign+PAssert$280/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$280/GroupGlobally/GroupDummyAndContents/Reify+PAssert$280/GroupGlobally/GroupDummyAndContents/Write [INFO] Job 2017-03-01_23_34_25-10100014877493162774 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_34_25-10100014877493162774. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-03-02T07:37:56.807Z: (e1028612ffba891e): Worker pool stopped. [INFO] 2017-03-02T07:38:00.929Z: S14: (6f4ab77687e4759e): Executing operation PAssert$277/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-03-02T07:38:00.950Z: S15: (6f4ab77687e471f6): Executing operation PAssert$277/GroupGlobally/GroupDummyAndContents/Read+PAssert$277/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$277/GroupGlobally/Values/Values/Map+PAssert$277/GroupGlobally/ParDo(Concat)+PAssert$277/GetPane/Map+PAssert$277/RunChecks [INFO] Job 2017-03-01_23_34_21-17527798268712538918 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_34_21-17527798268712538918. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-03-02T07:38:01.989Z: S10: (2e98163713366e70): Executing operation PAssert$280/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-03-02T07:38:02.011Z: S11: (2e98163713366938): Executing operation PAssert$280/GroupGlobally/GroupDummyAndContents/Read+PAssert$280/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$280/GroupGlobally/Values/Values/Map+PAssert$280/GroupGlobally/ParDo(Concat)+PAssert$280/GetPane/Map+PAssert$280/RunChecks [INFO] 2017-03-02T07:38:03.308Z: (df0a5f77c69a486e): Worker pool stopped. [INFO] 2017-03-02T07:38:05.601Z: S03: (f70bb21abd5e5695): Executing operation Distinct/Combine.perKey(Anonymous)/GroupByKey/Close [INFO] 2017-03-02T07:38:05.622Z: S04: (f70bb21abd5e5220): Executing operation PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-03-02T07:38:05.809Z: S05: (f70bb21abd5e5d43): Executing operation Distinct/Combine.perKey(Anonymous)/GroupByKey/Read+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract+Distinct/Keys/Keys/Map+PAssert$281/GroupGlobally/Window.Into()/Window.Assign+PAssert$281/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$281/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$281/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] Job 2017-03-01_23_34_22-11432880370390517665 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_34_22-11432880370390517665. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-03-02T07:38:08.536Z: (715e168a75870329): Cleaning up. [INFO] 2017-03-02T07:38:08.652Z: (715e168a7587078d): Stopping worker pool... [INFO] 2017-03-02T07:38:11.561Z: S08: (cffa0c4b0f7ec74c): Executing operation PAssert$278/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-03-02T07:38:11.593Z: S09: (cffa0c4b0f7ec834): Executing operation PAssert$278/GroupGlobally/GroupDummyAndContents/Read+PAssert$278/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$278/GroupGlobally/Values/Values/Map+PAssert$278/GroupGlobally/ParDo(Concat)+PAssert$278/GetPane/Map+PAssert$278/RunChecks [INFO] 2017-03-02T07:38:12.381Z: S06: (f70bb21abd5e5459): Executing operation PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-03-02T07:38:12.405Z: S07: (f70bb21abd5e5fe4): Executing operation PAssert$281/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-03-02T07:38:12.591Z: S08: (f70bb21abd5e5b07): Executing operation PAssert$281/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$281/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$281/GroupGlobally/GroupDummyAndContents/Reify+PAssert$281/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:38:12.596Z: S09: (4e3f15398cae3941): Executing operation PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$281/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$281/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$281/GroupGlobally/RewindowActuals/Window.Assign+PAssert$281/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$281/GroupGlobally/GroupDummyAndContents/Reify+PAssert$281/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-03-02T07:38:17.930Z: (fbb4893156938b93): Cleaning up. [INFO] 2017-03-02T07:38:18.045Z: (fbb489315693871f): Stopping worker pool... [INFO] Job 2017-03-01_23_34_45-4237541122480691311 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_34_45-4237541122480691311. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-03-02T07:38:22.491Z: S10: (4e3f15398cae3a33): Executing operation PAssert$281/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-03-02T07:38:22.516Z: S11: (4e3f15398cae31bb): Executing operation PAssert$281/GroupGlobally/GroupDummyAndContents/Read+PAssert$281/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$281/GroupGlobally/Values/Values/Map+PAssert$281/GroupGlobally/ParDo(Concat)+PAssert$281/GetPane/Map+PAssert$281/RunChecks [INFO] 2017-03-02T07:38:26.186Z: (f5f62e756af6e91b): Cleaning up. [INFO] 2017-03-02T07:38:26.191Z: (f5f62e756af6e33f): Stopping worker pool... [INFO] 2017-03-02T07:38:44.448Z: (429faddacc17c7a5): Worker pool stopped. [INFO] Job 2017-03-01_23_34_23-6611820601045734684 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_34_23-6611820601045734684. Found 4 success, 0 failures out of 4 expected assertions. [INFO] 2017-03-02T07:38:53.665Z: (3d4b1de5c378bfd5): Worker pool stopped. [INFO] Job 2017-03-01_23_35_09-1557930885312333187 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_35_09-1557930885312333187. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-03-02T07:39:08.659Z: (715e168a758702d8): Worker pool stopped. [INFO] Job 2017-03-01_23_35_42-954029029372626396 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_35_42-954029029372626396. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-03-02T07:39:28.051Z: (fbb48931569387c8): Worker pool stopped. [INFO] Job 2017-03-01_23_35_15-703693595862575173 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_35_15-703693595862575173. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-03-02T07:39:31.198Z: (f5f62e756af6eeda): Worker pool stopped. [INFO] Job 2017-03-01_23_35_46-15283430128075494459 finished with status DONE. [INFO] Found result while running Dataflow job 2017-03-01_23_35_46-15283430128075494459. Found 1 success, 0 failures out of 1 expected assertions. Running org.apache.beam.sdk.transforms.PartitionTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 265.455 sec - in org.apache.beam.sdk.transforms.PartitionTest Running org.apache.beam.sdk.transforms.DistinctTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 270.015 sec - in org.apache.beam.sdk.transforms.DistinctTest Running org.apache.beam.sdk.values.PDoneTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 sec - in org.apache.beam.sdk.values.PDoneTest Running org.apache.beam.sdk.transforms.ParDoLifecycleTest Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 263.349 sec - in org.apache.beam.sdk.transforms.ParDoLifecycleTest Running org.apache.beam.sdk.transforms.windowing.WindowTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 268.366 sec - in org.apache.beam.sdk.transforms.windowing.WindowTest Results : Tests run: 203, Failures: 0, Errors: 0, Skipped: 3 [JENKINS] Recording test results 2017-03-02T07:39:40.152 [INFO] 2017-03-02T07:39:40.152 [INFO] --- maven-dependency-plugin:3.0.0:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-03-02T07:39:40.208 [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 2017-03-02T07:39:44.210 [INFO] ------------------------------------------------------------------------ 2017-03-02T07:39:44.210 [INFO] Reactor Summary: 2017-03-02T07:39:44.210 [INFO] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 22.227 s] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 4.501 s] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 3.819 s] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: SDKs :: Common ...................... SUCCESS [ 1.352 s] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: SDKs :: Common :: Fn API ............ SUCCESS [ 15.170 s] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: SDKs :: Common :: Runner API ........ SUCCESS [ 5.405 s] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 1.249 s] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [02:20 min] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 2.128 s] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: Runners :: Core Java Construction ... SUCCESS [ 8.705 s] 2017-03-02T07:39:44.210 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:33 h] 2017-03-02T07:39:44.210 [INFO] ------------------------------------------------------------------------ 2017-03-02T07:39:44.210 [INFO] BUILD SUCCESS 2017-03-02T07:39:44.210 [INFO] ------------------------------------------------------------------------ 2017-03-02T07:39:44.210 [INFO] Total time: 01:37 h 2017-03-02T07:39:44.211 [INFO] Finished at: 2017-03-02T07:39:44+00:00 2017-03-02T07:39:44.898 [INFO] Final Memory: 179M/1441M 2017-03-02T07:39:44.898 [INFO] ------------------------------------------------------------------------ Waiting for Jenkins to finish collecting data channel stopped
