See <https://builds.apache.org/job/beam_PostCommit_Java_RunnableOnService_Dataflow/2336/display/redirect?page=changes>
Changes: [altay] Move google specific io clients to vendor directory. ------------------------------------------ [...truncated 3.85 MB...] [INFO] 2017-02-19T06:48:03.628Z: (abc23c6be04df816): Fusing consumer GroupByKey/GroupByWindow into GroupByKey/Read [INFO] 2017-02-19T06:48:03.631Z: (abc23c6be04df0b4): Fusing consumer Reshuffle/GroupByKey/GroupByWindow into Reshuffle/GroupByKey/Read [INFO] 2017-02-19T06:48:03.633Z: (abc23c6be04df952): Fusing consumer Reshuffle/Window.Into() into GroupByKey/GroupByWindow [INFO] 2017-02-19T06:48:03.635Z: (abc23c6be04df1f0): Fusing consumer PAssert$277/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$277/GroupGlobally/Window.Into() [INFO] 2017-02-19T06:48:03.637Z: (abc23c6be04dfa8e): Fusing consumer PAssert$277/GroupGlobally/Window.Into() into Reshuffle/ExpandIterable [INFO] 2017-02-19T06:48:03.639Z: (abc23c6be04df32c): Fusing consumer Reshuffle/ExpandIterable into Reshuffle/GroupByKey/GroupByWindow [INFO] 2017-02-19T06:48:03.642Z: (abc23c6be04dfbca): Fusing consumer PAssert$277/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$277/GroupGlobally/RewindowActuals [INFO] 2017-02-19T06:48:03.645Z: (abc23c6be04df468): Fusing consumer GroupByKey/Reify into Window.Into() [INFO] 2017-02-19T06:48:03.647Z: (abc23c6be04dfd06): Fusing consumer PAssert$277/GroupGlobally/GroupDummyAndContents/Reify into PAssert$277/GroupGlobally/NeverTrigger [INFO] 2017-02-19T06:48:03.650Z: (abc23c6be04df5a4): Fusing consumer PAssert$277/GroupGlobally/NeverTrigger into PAssert$277/GroupGlobally/RemoveDummyTriggering [INFO] 2017-02-19T06:48:03.652Z: (abc23c6be04dfe42): Fusing consumer PAssert$277/GroupGlobally/RemoveDummyTriggering into PAssert$277/GroupGlobally/WindowIntoDummy [INFO] 2017-02-19T06:48:03.654Z: (abc23c6be04df6e0): Fusing consumer PAssert$277/GroupGlobally/WindowIntoDummy into PAssert$277/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-02-19T06:48:03.768Z: (abc23c6be04dff96): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-02-19T06:48:03.818Z: S01: (841292815cd823b0): Executing operation GroupByKey/Create [INFO] 2017-02-19T06:48:04.024Z: (209813a79ab9997c): Starting 1 workers... [INFO] 2017-02-19T06:48:04.043Z: S02: (841292815cd822d1): Executing operation Create.Values/Read(CreateSource)+Window.Into()+GroupByKey/Reify+GroupByKey/Write [INFO] 2017-02-19T06:48:03.442Z: (4ff1b0b164a18bfb): Cleaning up. [INFO] 2017-02-19T06:48:03.524Z: (4ff1b0b164a18b47): Stopping worker pool... [INFO] 2017-02-19T06:48:03.743Z: S08: (3fa0ec54440593e3): Executing operation PAssert$270/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-19T06:48:03.768Z: S09: (3fa0ec544405941e): Executing operation PAssert$270/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-19T06:48:03.979Z: S10: (3fa0ec5444059d71): Executing operation PAssert$270/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$270/GroupGlobally/WindowIntoDummy+PAssert$270/GroupGlobally/RemoveDummyTriggering+PAssert$270/GroupGlobally/NeverTrigger+PAssert$270/GroupGlobally/GroupDummyAndContents/Reify+PAssert$270/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:48:03.984Z: S11: (2a623fe9240bea9c): Executing operation PAssert$270/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$270/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$270/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$270/GroupGlobally/RewindowActuals+PAssert$270/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$270/GroupGlobally/RemoveActualsTriggering+PAssert$270/GroupGlobally/NeverTrigger+PAssert$270/GroupGlobally/GroupDummyAndContents/Reify+PAssert$270/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:48:04.353Z: (23964af109545aea): Checking required Cloud APIs are enabled. [INFO] 2017-02-19T06:48:04.756Z: (23964af109545e1a): Expanding GroupByKey operations into optimizable parts. [INFO] 2017-02-19T06:48:04.758Z: (23964af109545280): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns [INFO] 2017-02-19T06:48:04.766Z: (23964af109545418): Annotating graph with Autotuner information. [INFO] 2017-02-19T06:48:04.777Z: (23964af109545ce4): Fusing adjacent ParDo, Read, Write, and Flatten operations [INFO] 2017-02-19T06:48:04.783Z: (23964af109545a16): Unzipping flatten s17 for input s13.13 [INFO] 2017-02-19T06:48:04.786Z: (23964af109545e7c): Fusing unzipped copy of PAssert$276/GroupGlobally/NeverTrigger, through flatten , into producer PAssert$276/GroupGlobally/RemoveActualsTriggering [INFO] 2017-02-19T06:48:04.788Z: (23964af1095452e2): Fusing consumer PAssert$276/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$276/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-02-19T06:48:04.791Z: (23964af109545748): Fusing consumer PAssert$276/RunChecks into PAssert$276/GetPane/Map [INFO] 2017-02-19T06:48:04.798Z: (23964af10954547a): Unzipping flatten s17-u31 for input s18.18-c29 [INFO] 2017-02-19T06:48:04.800Z: (23964af1095458e0): Fusing unzipped copy of PAssert$276/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$276/GroupGlobally/NeverTrigger [INFO] 2017-02-19T06:48:04.802Z: (23964af109545d46): Fusing consumer PAssert$276/GroupGlobally/Values/Values/Map into PAssert$276/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-02-19T06:48:04.804Z: (23964af1095451ac): Fusing consumer PAssert$276/GroupGlobally/ParDo(Concat) into PAssert$276/GroupGlobally/Values/Values/Map [INFO] 2017-02-19T06:48:04.806Z: (23964af109545612): Fusing consumer PAssert$276/GetPane/Map into PAssert$276/GroupGlobally/ParDo(Concat) [INFO] 2017-02-19T06:48:04.815Z: (23964af1095457aa): Unzipping flatten s17-u31-u36 for input s19-reify-value1-c34 [INFO] 2017-02-19T06:48:04.818Z: (23964af109545c10): Fusing unzipped copy of PAssert$276/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$276/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-02-19T06:48:04.820Z: (23964af109545076): Fusing consumer PAssert$276/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$276/GroupGlobally/RewindowActuals [INFO] 2017-02-19T06:48:04.823Z: (23964af1095454dc): Fusing consumer PAssert$276/GroupGlobally/RemoveActualsTriggering into PAssert$276/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-02-19T06:48:04.826Z: (23964af109545942): Fusing consumer PAssert$276/GroupGlobally/RewindowActuals into PAssert$276/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-02-19T06:48:04.828Z: (23964af109545da8): Fusing consumer PAssert$276/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$276/GroupGlobally/Window.Into() [INFO] 2017-02-19T06:48:04.830Z: (23964af10954520e): Fusing consumer PAssert$276/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-02-19T06:48:04.832Z: (23964af109545674): Fusing consumer Reshuffle/GroupByKey/Write into Reshuffle/GroupByKey/Reify [INFO] 2017-02-19T06:48:04.834Z: (23964af109545ada): Fusing consumer PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-02-19T06:48:04.836Z: (23964af109545f40): Fusing consumer PAssert$276/GroupGlobally/Window.Into() into Reshuffle/ExpandIterable [INFO] 2017-02-19T06:48:04.839Z: (23964af1095453a6): Fusing consumer PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$276/GroupGlobally/GatherAllOutputs/Window.Into() [INFO] 2017-02-19T06:48:04.841Z: (23964af10954580c): Fusing consumer Reshuffle/Window.Into() into Create.Values/Read(CreateSource) [INFO] 2017-02-19T06:48:04.843Z: (23964af109545c72): Fusing consumer Reshuffle/GroupByKey/Reify into Reshuffle/Window.Into() [INFO] 2017-02-19T06:48:04.845Z: (23964af1095450d8): Fusing consumer PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-02-19T06:48:04.847Z: (23964af10954553e): Fusing consumer Reshuffle/ExpandIterable into Reshuffle/GroupByKey/GroupByWindow [INFO] 2017-02-19T06:48:04.850Z: (23964af1095459a4): Fusing consumer PAssert$276/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$276/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-02-19T06:48:04.853Z: (23964af109545e0a): Fusing consumer PAssert$276/GroupGlobally/GatherAllOutputs/Window.Into() into PAssert$276/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-02-19T06:48:04.855Z: (23964af109545270): Fusing consumer Reshuffle/GroupByKey/GroupByWindow into Reshuffle/GroupByKey/Read [INFO] 2017-02-19T06:48:04.858Z: (23964af1095456d6): Fusing consumer PAssert$276/GroupGlobally/GroupDummyAndContents/Write into PAssert$276/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-02-19T06:48:04.860Z: (23964af109545b3c): Fusing consumer PAssert$276/GroupGlobally/GroupDummyAndContents/Reify into PAssert$276/GroupGlobally/NeverTrigger [INFO] 2017-02-19T06:48:04.863Z: (23964af109545fa2): Fusing consumer PAssert$276/GroupGlobally/NeverTrigger into PAssert$276/GroupGlobally/RemoveDummyTriggering [INFO] 2017-02-19T06:48:04.865Z: (23964af109545408): Fusing consumer PAssert$276/GroupGlobally/WindowIntoDummy into PAssert$276/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-02-19T06:48:04.867Z: (23964af10954586e): Fusing consumer PAssert$276/GroupGlobally/RemoveDummyTriggering into PAssert$276/GroupGlobally/WindowIntoDummy [INFO] 2017-02-19T06:48:04.969Z: (23964af109545e5c): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-02-19T06:48:05.024Z: S01: (178f4659b60f3576): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-19T06:48:05.230Z: (a063a9abd0325f81): Starting 1 workers... [INFO] 2017-02-19T06:48:05.261Z: S02: (178f4659b60f3a69): Executing operation Create.Values/Read(CreateSource)+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-19T06:48:07.106Z: S08: (43fb40489599f205): Executing operation PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-19T06:48:07.125Z: S09: (43fb40489599fcf4): Executing operation PAssert$271/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-19T06:48:07.316Z: S10: (43fb40489599f19b): Executing operation PAssert$271/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$271/GroupGlobally/WindowIntoDummy+PAssert$271/GroupGlobally/RemoveDummyTriggering+PAssert$271/GroupGlobally/NeverTrigger+PAssert$271/GroupGlobally/GroupDummyAndContents/Reify+PAssert$271/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:48:07.322Z: S11: (1cd3af83b12d3ef2): Executing operation PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$271/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$271/GroupGlobally/RewindowActuals+PAssert$271/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$271/GroupGlobally/RemoveActualsTriggering+PAssert$271/GroupGlobally/NeverTrigger+PAssert$271/GroupGlobally/GroupDummyAndContents/Reify+PAssert$271/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:48:14.478Z: S12: (2a623fe9240be80a): Executing operation PAssert$270/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-19T06:48:14.502Z: S13: (2a623fe9240bee02): Executing operation PAssert$270/GroupGlobally/GroupDummyAndContents/Read+PAssert$270/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$270/GroupGlobally/Values/Values/Map+PAssert$270/GroupGlobally/ParDo(Concat)+PAssert$270/GetPane/Map+PAssert$270/RunChecks [INFO] 2017-02-19T06:48:17.732Z: S12: (43fb40489599f02f): Executing operation PAssert$271/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-19T06:48:17.751Z: S13: (43fb40489599f9e7): Executing operation PAssert$271/GroupGlobally/GroupDummyAndContents/Read+PAssert$271/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$271/GroupGlobally/Values/Values/Map+PAssert$271/GroupGlobally/ParDo(Concat)+PAssert$271/GetPane/Map+PAssert$271/RunChecks [INFO] 2017-02-19T06:48:21.073Z: (750cd46ee2c9532e): Cleaning up. [INFO] 2017-02-19T06:48:21.185Z: (750cd46ee2c95fca): Stopping worker pool... [INFO] 2017-02-19T06:48:22.040Z: (f0cf11723de5a023): Workers have started successfully. [INFO] 2017-02-19T06:48:22.300Z: (e876f0a003dcf38f): Workers have started successfully. [INFO] 2017-02-19T06:48:22.275Z: (3598196f3e596710): Workers have started successfully. [INFO] 2017-02-19T06:48:24.212Z: (848bc82dc711f7f5): Cleaning up. [INFO] 2017-02-19T06:48:24.330Z: (848bc82dc711f8d1): Stopping worker pool... [INFO] 2017-02-19T06:48:44.284Z: S04: (5e09032e0a4804ae): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-19T06:48:44.472Z: S05: (5e09032e0a48015d): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-19T06:48:44.671Z: S03: (383b1139a6934521): Executing operation GroupByKey/Close [INFO] 2017-02-19T06:48:44.691Z: S04: (383b1139a6934709): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+ParDo(Anonymous) [INFO] 2017-02-19T06:48:44.746Z: S03: (cf3aefd2a791c246): Executing operation GroupByKey/Close [INFO] 2017-02-19T06:48:44.770Z: S04: (cf3aefd2a791ce4e): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+ParDo(Anonymous) [INFO] 2017-02-19T06:48:51.596Z: (5ea7530f085a9de2): Cleaning up. [INFO] 2017-02-19T06:48:51.601Z: (5ea7530f085a9cde): Stopping worker pool... [INFO] 2017-02-19T06:48:51.212Z: S06: (5e09032e0a480ecb): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-19T06:48:51.232Z: S07: (5e09032e0a480582): Executing operation PAssert$272/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-19T06:48:51.423Z: S08: (5e09032e0a480231): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$272/GroupGlobally/Window.Into()+PAssert$272/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$272/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$272/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$272/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$272/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-19T06:48:51.814Z: (ca949ef019db3bba): Cleaning up. [INFO] 2017-02-19T06:48:51.819Z: (ca949ef019db34ae): Stopping worker pool... [INFO] 2017-02-19T06:48:54.586Z: (dcd8283ee709e26f): Worker pool stopped. [INFO] 2017-02-19T06:48:53.909Z: (5a443e1bef1218e9): Worker pool stopped. [INFO] Job 2017-02-18_22_45_06-15587313870510816130 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_45_06-15587313870510816130. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-02-18_22_45_06-10093942162945359549 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_45_06-10093942162945359549. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-19T06:48:58.533Z: (4ff1b0b164a18ec0): Worker pool stopped. [INFO] 2017-02-19T06:48:58.801Z: S09: (5e09032e0a480f9f): Executing operation PAssert$272/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-19T06:48:58.826Z: S10: (5e09032e0a480656): Executing operation PAssert$272/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-19T06:48:59.016Z: S11: (5e09032e0a480305): Executing operation PAssert$272/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$272/GroupGlobally/WindowIntoDummy+PAssert$272/GroupGlobally/RemoveDummyTriggering+PAssert$272/GroupGlobally/NeverTrigger+PAssert$272/GroupGlobally/GroupDummyAndContents/Reify+PAssert$272/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:48:59.024Z: S12: (d846cfec30223f98): Executing operation PAssert$272/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$272/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$272/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$272/GroupGlobally/RewindowActuals+PAssert$272/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$272/GroupGlobally/RemoveActualsTriggering+PAssert$272/GroupGlobally/NeverTrigger+PAssert$272/GroupGlobally/GroupDummyAndContents/Reify+PAssert$272/GroupGlobally/GroupDummyAndContents/Write [INFO] Job 2017-02-18_22_45_14-17651289593937711977 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_45_14-17651289593937711977. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-19T06:49:09.492Z: S13: (5e09032e0a480bf9): Executing operation PAssert$272/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-19T06:49:09.547Z: S14: (5e09032e0a4801f1): Executing operation PAssert$272/GroupGlobally/GroupDummyAndContents/Read+PAssert$272/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$272/GroupGlobally/Values/Values/Map+PAssert$272/GroupGlobally/ParDo(Concat)+PAssert$272/GetPane/Map+PAssert$272/RunChecks [INFO] 2017-02-19T06:49:16.077Z: (3b5aa998d39d79e0): Cleaning up. [INFO] 2017-02-19T06:49:16.197Z: (3b5aa998d39d7924): Stopping worker pool... [INFO] 2017-02-19T06:49:21.206Z: (b9ad62eb616197e0): Workers have started successfully. [INFO] 2017-02-19T06:49:31.195Z: (750cd46ee2c9593f): Worker pool stopped. [INFO] Job 2017-02-18_22_45_14-9747646368952266033 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_45_14-9747646368952266033. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-19T06:49:34.338Z: (848bc82dc711fd76): Worker pool stopped. [INFO] Job 2017-02-18_22_45_26-945685640371413014 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_45_26-945685640371413014. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-19T06:49:38.670Z: (1ce979131dfa39dd): Workers have started successfully. [INFO] 2017-02-19T06:49:40.431Z: S03: (50dedbe5e8841afe): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-19T06:49:40.452Z: S04: (50dedbe5e8841bd7): Executing operation PAssert$273/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-19T06:49:40.640Z: S05: (50dedbe5e8841f38): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$273/GroupGlobally/Window.Into()+PAssert$273/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$273/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$273/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$273/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$273/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-19T06:49:47.957Z: S06: (50dedbe5e88410ea): Executing operation PAssert$273/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-19T06:49:47.978Z: S07: (50dedbe5e88411c3): Executing operation PAssert$273/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-19T06:49:48.168Z: S08: (50dedbe5e8841524): Executing operation PAssert$273/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$273/GroupGlobally/WindowIntoDummy+PAssert$273/GroupGlobally/RemoveDummyTriggering+PAssert$273/GroupGlobally/NeverTrigger+PAssert$273/GroupGlobally/GroupDummyAndContents/Reify+PAssert$273/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:49:48.174Z: S09: (f11b5ab1208906ba): 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+PAssert$273/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$273/GroupGlobally/RemoveActualsTriggering+PAssert$273/GroupGlobally/NeverTrigger+PAssert$273/GroupGlobally/GroupDummyAndContents/Reify+PAssert$273/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:49:50.161Z: (3d408a84be293669): Workers have started successfully. [INFO] 2017-02-19T06:49:51.608Z: (5ea7530f085a9c1b): Worker pool stopped. [INFO] 2017-02-19T06:49:53.707Z: S03: (9cf8f8aedeff87a4): Executing operation GroupByKey/Close [INFO] 2017-02-19T06:49:53.734Z: S04: (9cf8f8aedeff8667): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-19T06:49:53.921Z: S05: (9cf8f8aedeff8082): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] Job 2017-02-18_22_46_24-2387188181670847865 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_46_24-2387188181670847865. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-02-19T06:49:58.709Z: S10: (50dedbe5e88410f0): Executing operation PAssert$273/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-19T06:49:57.147Z: (5c863a7fecdc00a0): Workers have started successfully. [INFO] 2017-02-19T06:49:56.825Z: (ca949ef019db3365): Worker pool stopped. [INFO] 2017-02-19T06:49:58.730Z: S11: (50dedbe5e8841378): 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] Job 2017-02-18_22_46_23-11488482081610630312 finished with status DONE. [INFO] 2017-02-19T06:50:00.315Z: S06: (9cf8f8aedeff8e08): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-19T06:50:00.343Z: S07: (9cf8f8aedeff8ccb): Executing operation PAssert$274/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-19T06:50:00.525Z: S08: (9cf8f8aedeff86e6): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$274/GroupGlobally/Window.Into()+PAssert$274/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$274/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$274/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$274/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$274/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] Found result while running Dataflow job 2017-02-18_22_46_23-11488482081610630312. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-02-19T06:50:04.206Z: (79e909bf2818977d): Workers have started successfully. [INFO] 2017-02-19T06:50:05.329Z: (45d3d83a7a34e1b0): Stopping worker pool... [INFO] 2017-02-19T06:50:07.755Z: S09: (9cf8f8aedeff846c): Executing operation PAssert$274/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-19T06:50:07.778Z: S10: (9cf8f8aedeff832f): Executing operation PAssert$274/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-19T06:50:07.967Z: S11: (9cf8f8aedeff8d4a): Executing operation PAssert$274/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$274/GroupGlobally/WindowIntoDummy+PAssert$274/GroupGlobally/RemoveDummyTriggering+PAssert$274/GroupGlobally/NeverTrigger+PAssert$274/GroupGlobally/GroupDummyAndContents/Reify+PAssert$274/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:50:07.973Z: S12: (4e366352d340fafb): 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+PAssert$274/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$274/GroupGlobally/RemoveActualsTriggering+PAssert$274/GroupGlobally/NeverTrigger+PAssert$274/GroupGlobally/GroupDummyAndContents/Reify+PAssert$274/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:50:09.199Z: S03: (f6ef240c70dc8fb7): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-19T06:50:09.219Z: S04: (f6ef240c70dc87ea): Executing operation PAssert$275/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-19T06:50:09.409Z: S05: (f6ef240c70dc8af5): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$275/GroupGlobally/Window.Into()+PAssert$275/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$275/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$275/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$275/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$275/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-19T06:50:16.476Z: S13: (4e366352d340f9f1): Executing operation PAssert$274/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-19T06:50:16.501Z: S14: (4e366352d340fd09): 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-02-19T06:50:16.725Z: S06: (f6ef240c70dc8b5b): Executing operation PAssert$275/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-19T06:50:16.744Z: S07: (f6ef240c70dc838e): Executing operation PAssert$275/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-19T06:50:16.932Z: S08: (f6ef240c70dc8699): Executing operation PAssert$275/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$275/GroupGlobally/WindowIntoDummy+PAssert$275/GroupGlobally/RemoveDummyTriggering+PAssert$275/GroupGlobally/NeverTrigger+PAssert$275/GroupGlobally/GroupDummyAndContents/Reify+PAssert$275/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:50:16.937Z: S09: (1c2ef899406766f5): 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+PAssert$275/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$275/GroupGlobally/RemoveActualsTriggering+PAssert$275/GroupGlobally/NeverTrigger+PAssert$275/GroupGlobally/GroupDummyAndContents/Reify+PAssert$275/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:50:16.205Z: (3b5aa998d39d7097): Worker pool stopped. [INFO] 2017-02-19T06:50:19.088Z: S03: (841292815cd82b9d): Executing operation GroupByKey/Close [INFO] 2017-02-19T06:50:19.106Z: S04: (841292815cd82a36): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-19T06:50:19.296Z: S05: (841292815cd82957): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-19T06:50:21.979Z: (8f972685180f68f1): Cleaning up. [INFO] Job 2017-02-18_22_46_28-15270353439772403523 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_46_28-15270353439772403523. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-19T06:50:22.089Z: (8f972685180f620d): Stopping worker pool... [INFO] 2017-02-19T06:50:23.406Z: S03: (178f4659b60f338d): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-19T06:50:23.427Z: S04: (178f4659b60f3268): Executing operation PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-19T06:50:23.617Z: S05: (178f4659b60f375b): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$276/GroupGlobally/Window.Into()+PAssert$276/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$276/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$276/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-19T06:50:25.888Z: S06: (841292815cd82689): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-19T06:50:25.906Z: S07: (841292815cd82522): Executing operation PAssert$277/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-19T06:50:26.096Z: S08: (841292815cd82443): Executing operation Reshuffle/GroupByKey/Read+Reshuffle/GroupByKey/GroupByWindow+Reshuffle/ExpandIterable+PAssert$277/GroupGlobally/Window.Into()+PAssert$277/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$277/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$277/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$277/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$277/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-19T06:50:27.575Z: S11: (f6ef240c70dc81b5): 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-02-19T06:50:31.262Z: S06: (178f4659b60f3511): Executing operation PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-19T06:50:31.283Z: S07: (178f4659b60f33ec): Executing operation PAssert$276/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-19T06:50:32.571Z: S09: (841292815cd82175): Executing operation PAssert$277/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-19T06:50:32.589Z: S10: (841292815cd8200e): Executing operation PAssert$277/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-19T06:50:32.775Z: S11: (841292815cd82f2f): Executing operation PAssert$277/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$277/GroupGlobally/WindowIntoDummy+PAssert$277/GroupGlobally/RemoveDummyTriggering+PAssert$277/GroupGlobally/NeverTrigger+PAssert$277/GroupGlobally/GroupDummyAndContents/Reify+PAssert$277/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:50:32.779Z: S12: (de9c1b3e77e33a9b): 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+PAssert$277/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$277/GroupGlobally/RemoveActualsTriggering+PAssert$277/GroupGlobally/NeverTrigger+PAssert$277/GroupGlobally/GroupDummyAndContents/Reify+PAssert$277/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:50:31.471Z: S08: (178f4659b60f38df): Executing operation PAssert$276/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$276/GroupGlobally/WindowIntoDummy+PAssert$276/GroupGlobally/RemoveDummyTriggering+PAssert$276/GroupGlobally/NeverTrigger+PAssert$276/GroupGlobally/GroupDummyAndContents/Reify+PAssert$276/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:50:31.477Z: S09: (60c6d0f543b26ef1): 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+PAssert$276/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$276/GroupGlobally/RemoveActualsTriggering+PAssert$276/GroupGlobally/NeverTrigger+PAssert$276/GroupGlobally/GroupDummyAndContents/Reify+PAssert$276/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-19T06:50:34.105Z: (fc0d60e7d5c64c77): Cleaning up. [INFO] 2017-02-19T06:50:34.224Z: (fc0d60e7d5c64abb): Stopping worker pool... [INFO] 2017-02-19T06:50:41.066Z: S10: (60c6d0f543b2657b): Executing operation PAssert$276/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-19T06:50:41.096Z: S11: (60c6d0f543b26863): 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-02-19T06:50:40.489Z: S13: (de9c1b3e77e3324d): Executing operation PAssert$277/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-19T06:50:40.508Z: S14: (de9c1b3e77e33cd5): 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] 2017-02-19T06:50:46.036Z: (abc23c6be04df037): Cleaning up. [INFO] 2017-02-19T06:50:46.156Z: (abc23c6be04df173): Stopping worker pool... [INFO] 2017-02-19T06:50:45.605Z: (23964af109545759): Cleaning up. [INFO] 2017-02-19T06:50:45.723Z: (23964af109545025): Stopping worker pool... [INFO] 2017-02-19T06:51:10.335Z: (45d3d83a7a34e7bb): Worker pool stopped. [INFO] Job 2017-02-18_22_47_13-16635408397384407867 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_47_13-16635408397384407867. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-19T06:51:22.097Z: (8f972685180f68e2): Worker pool stopped. [INFO] Job 2017-02-18_22_47_34-7322387277467802179 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_47_34-7322387277467802179. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-19T06:51:39.231Z: (fc0d60e7d5c6416e): Worker pool stopped. [INFO] Job 2017-02-18_22_47_43-1040976547706706206 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_47_43-1040976547706706206. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-19T06:51:55.730Z: (23964af109545ebe): Worker pool stopped. [INFO] Job 2017-02-18_22_47_59-480890207160125330 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_47_59-480890207160125330. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-19T06:52:06.163Z: (abc23c6be04dfe60): Worker pool stopped. [INFO] Job 2017-02-18_22_47_58-9609986148187332931 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-18_22_47_58-9609986148187332931. Found 1 success, 0 failures out of 1 expected assertions. 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.util.ReshuffleTest Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 344.337 sec - in org.apache.beam.sdk.util.ReshuffleTest Running org.apache.beam.sdk.transforms.windowing.WindowTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 220.403 sec - in org.apache.beam.sdk.transforms.windowing.WindowTest Results : Tests run: 197, Failures: 0, Errors: 0, Skipped: 3 [JENKINS] Recording test results 2017-02-19T06:52:14.189 [INFO] 2017-02-19T06:52:14.189 [INFO] --- maven-dependency-plugin:3.0.0:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-02-19T06:52:14.241 [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 2017-02-19T06:52:17.884 [INFO] ------------------------------------------------------------------------ 2017-02-19T06:52:17.884 [INFO] Reactor Summary: 2017-02-19T06:52:17.884 [INFO] 2017-02-19T06:52:17.884 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 18.546 s] 2017-02-19T06:52:17.884 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 3.690 s] 2017-02-19T06:52:17.884 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.617 s] 2017-02-19T06:52:17.884 [INFO] Apache Beam :: SDKs :: Common ...................... SUCCESS [ 1.188 s] 2017-02-19T06:52:17.884 [INFO] Apache Beam :: SDKs :: Common :: Fn API ............ SUCCESS [ 12.538 s] 2017-02-19T06:52:17.885 [INFO] Apache Beam :: SDKs :: Common :: Runner API ........ SUCCESS [ 5.096 s] 2017-02-19T06:52:17.885 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 1.239 s] 2017-02-19T06:52:17.885 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [02:23 min] 2017-02-19T06:52:17.885 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 1.599 s] 2017-02-19T06:52:17.885 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:22 h] 2017-02-19T06:52:17.885 [INFO] ------------------------------------------------------------------------ 2017-02-19T06:52:17.885 [INFO] BUILD SUCCESS 2017-02-19T06:52:17.885 [INFO] ------------------------------------------------------------------------ 2017-02-19T06:52:17.885 [INFO] Total time: 01:26 h 2017-02-19T06:52:17.885 [INFO] Finished at: 2017-02-19T06:52:17+00:00 2017-02-19T06:52:18.547 [INFO] Final Memory: 202M/1398M 2017-02-19T06:52:18.547 [INFO] ------------------------------------------------------------------------ channel stopped
