See <https://builds.apache.org/job/beam_PostCommit_Java_RunnableOnService_Dataflow/2317/changes>
Changes: [peihe] [BEAM-59] Beam GcsFileSystem: port fileSizes() from GcsUtil for batch [klk] Add ability to bundle any message with components in Runner API ------------------------------------------ [...truncated 28082 lines...] [INFO] 2017-02-17T02:33:12.623Z: (d17d10b8526fd5e): Fusing consumer PAssert$277/GroupGlobally/GatherAllOutputs/Window.Into() into PAssert$277/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-02-17T02:33:12.625Z: (d17d10b8526f19c): Fusing consumer Reshuffle/GroupByKey/GroupByWindow into Reshuffle/GroupByKey/Read [INFO] 2017-02-17T02:33:12.628Z: (d17d10b8526f5da): Fusing consumer PAssert$277/GroupGlobally/GroupDummyAndContents/Write into PAssert$277/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-02-17T02:33:12.630Z: (d17d10b8526fa18): Fusing consumer PAssert$277/GroupGlobally/GroupDummyAndContents/Reify into PAssert$277/GroupGlobally/NeverTrigger [INFO] 2017-02-17T02:33:12.633Z: (d17d10b8526fe56): Fusing consumer PAssert$277/GroupGlobally/NeverTrigger into PAssert$277/GroupGlobally/RemoveDummyTriggering [INFO] 2017-02-17T02:33:12.635Z: (d17d10b8526f294): Fusing consumer PAssert$277/GroupGlobally/WindowIntoDummy into PAssert$277/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-02-17T02:33:12.638Z: (d17d10b8526f6d2): Fusing consumer PAssert$277/GroupGlobally/RemoveDummyTriggering into PAssert$277/GroupGlobally/WindowIntoDummy [INFO] 2017-02-17T02:33:12.762Z: (d17d10b8526f5b8): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-02-17T02:33:12.833Z: S01: (697db8bcd4c97146): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-17T02:33:13.043Z: (991672ea1976e443): Starting 1 workers... [INFO] 2017-02-17T02:33:13.084Z: S02: (697db8bcd4c975eb): Executing operation Create.Values/Read(CreateSource)+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-17T02:33:14.953Z: (26271bb151182712): Workers have started successfully. [INFO] 2017-02-17T02:33:34.548Z: (dfc356fa56197fde): Workers have started successfully. [INFO] 2017-02-17T02:33:34.022Z: (37226ebc1e7bc67b): Workers have started successfully. [INFO] 2017-02-17T02:33:34.172Z: (8f374db9c6845b00): Workers have started successfully. [INFO] 2017-02-17T02:33:36.496Z: (8a6443d8cd94ea7c): Workers have started successfully. [INFO] 2017-02-17T02:33:41.956Z: S05: (a399a053de30868e): Executing operation CoGroupByKey/GroupByKey/Close [INFO] 2017-02-17T02:33:41.980Z: S06: (a399a053de308647): Executing operation PAssert$268/CreateActual/GatherPanes/GroupByKey/Create [INFO] 2017-02-17T02:33:42.166Z: S07: (a399a053de308788): Executing operation CoGroupByKey/GroupByKey/Read+CoGroupByKey/GroupByKey/GroupByWindow+CoGroupByKey/ConstructCoGbkResultFn+PAssert$268/CreateActual/FilterActuals+PAssert$268/CreateActual/GatherPanes/ParDo(ReifyTimestampsAndWindows)+PAssert$268/CreateActual/GatherPanes/WithKeys/AddKeys/Map+PAssert$268/CreateActual/GatherPanes/Window.Into()+PAssert$268/CreateActual/GatherPanes/GroupByKey/Reify+PAssert$268/CreateActual/GatherPanes/GroupByKey/Write [INFO] 2017-02-17T02:33:42.476Z: S04: (f8d57fc086c1a1a2): Executing operation CoGroupByKey/GroupByKey/Close [INFO] 2017-02-17T02:33:42.498Z: S05: (f8d57fc086c1a38d): Executing operation PAssert$269/CreateActual/GatherPanes/GroupByKey/Create [INFO] 2017-02-17T02:33:42.688Z: S06: (f8d57fc086c1a010): Executing operation CoGroupByKey/GroupByKey/Read+CoGroupByKey/GroupByKey/GroupByWindow+CoGroupByKey/ConstructCoGbkResultFn+PAssert$269/CreateActual/FilterActuals+PAssert$269/CreateActual/GatherPanes/ParDo(ReifyTimestampsAndWindows)+PAssert$269/CreateActual/GatherPanes/WithKeys/AddKeys/Map+PAssert$269/CreateActual/GatherPanes/Window.Into()+PAssert$269/CreateActual/GatherPanes/GroupByKey/Reify+PAssert$269/CreateActual/GatherPanes/GroupByKey/Write [INFO] 2017-02-17T02:33:49.568Z: S07: (f8d57fc086c1a3e6): Executing operation PAssert$269/CreateActual/GatherPanes/GroupByKey/Close [INFO] 2017-02-17T02:33:49.591Z: S08: (f8d57fc086c1a5d1): Executing operation PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForData/DataflowRunner.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-02-17T02:33:49.778Z: S09: (f8d57fc086c1a9a7): Executing operation PAssert$269/CreateActual/GatherPanes/GroupByKey/Read+PAssert$269/CreateActual/GatherPanes/GroupByKey/GroupByWindow+PAssert$269/CreateActual/GatherPanes/Values/Values/Map+PAssert$269/CreateActual/ExtractPane/Map+PAssert$269/CreateActual/Flatten.FlattenIterables/FlattenIterables/FlatMap+PAssert$269/CreateActual/RewindowActuals+PAssert$269/CreateActual/ParDo(Anonymous)+PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)+PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForData/DataflowRunner.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-02-17T02:33:48.164Z: S08: (a399a053de3086fa): Executing operation PAssert$268/CreateActual/GatherPanes/GroupByKey/Close [INFO] 2017-02-17T02:33:48.190Z: S09: (a399a053de3086b3): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForData/DataflowRunner.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-02-17T02:33:48.377Z: S10: (a399a053de308625): Executing operation PAssert$268/CreateActual/GatherPanes/GroupByKey/Read+PAssert$268/CreateActual/GatherPanes/GroupByKey/GroupByWindow+PAssert$268/CreateActual/GatherPanes/Values/Values/Map+PAssert$268/CreateActual/ExtractPane/Map+PAssert$268/CreateActual/Flatten.FlattenIterables/FlattenIterables/FlatMap+PAssert$268/CreateActual/RewindowActuals+PAssert$268/CreateActual/ParDo(Anonymous)+PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)+PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForData/DataflowRunner.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-02-17T02:33:52.117Z: S11: (a399a053de308597): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForData/DataflowRunner.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-02-17T02:33:52.141Z: S12: (a399a053de308381): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForSize/Create [INFO] 2017-02-17T02:33:52.146Z: S13: (7d898b64ee2e1b26): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForKeys/Create [INFO] 2017-02-17T02:33:52.338Z: S14: (7d898b64ee2e18b6): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForData/DataflowRunner.GroupByKeyAndSortValuesOnly/Read+PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/ParMultiDo(ToIsmRecordForMapLike)+PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForKeys/Write+PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForSize/Write [INFO] 2017-02-17T02:33:53.134Z: S03: (b259408bbae7dbe7): Executing operation GroupByKey/Close [INFO] 2017-02-17T02:33:53.154Z: S04: (b259408bbae7dabf): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+ParDo(Anonymous) [INFO] 2017-02-17T02:33:56.679Z: S13: (e4e04abd3dca32ed): Executing operation PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForData/DataflowRunner.GroupByKeyAndSortValuesOnly/Read+PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/ParMultiDo(ToIsmRecordForMapLike)+PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForKeys/Write+PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForSize/Write [INFO] 2017-02-17T02:33:56.378Z: (dc60c7aced2e9f20): Workers have started successfully. [INFO] 2017-02-17T02:33:59.853Z: (3fdc1626f106223c): Stopping worker pool... [INFO] 2017-02-17T02:34:00.304Z: S15: (a399a053de308124): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForSize/Close [INFO] 2017-02-17T02:34:00.308Z: S17: (7d898b64ee2e1697): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForKeys/Close [INFO] 2017-02-17T02:34:00.332Z: S16: (7d898b64ee2e1d5f): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForSize/Read+PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/ParDo(ToIsmMetadataRecordForSize) [INFO] 2017-02-17T02:34:00.339Z: S18: (a399a053de3082ac): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForKeys/Read+PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/ParDo(ToIsmMetadataRecordForKey) [INFO] 2017-02-17T02:34:01.978Z: S03: (99177f462f2e00be): Executing operation GroupByKey/Close [INFO] 2017-02-17T02:34:02.001Z: S04: (99177f462f2e04b6): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+ParDo(Anonymous) [INFO] 2017-02-17T02:34:06.757Z: S14: (29372428a9bf4ed6): Executing operation PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForSize/Close [INFO] 2017-02-17T02:34:06.760Z: S16: (f8d57fc086c1abeb): Executing operation PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForKeys/Close [INFO] 2017-02-17T02:34:06.781Z: S15: (f8d57fc086c1a683): Executing operation PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForSize/Read+PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/ParDo(ToIsmMetadataRecordForSize) [INFO] 2017-02-17T02:34:06.785Z: S17: (29372428a9bf4fee): Executing operation PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/GBKaSVForKeys/Read+PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/ParDo(ToIsmMetadataRecordForKey) [INFO] 2017-02-17T02:34:06.928Z: S04: (54e89656bc6485c0): Executing operation CoGroupByKey/GroupByKey/Close [INFO] 2017-02-17T02:34:06.948Z: S05: (54e89656bc64850b): Executing operation PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-17T02:34:07.137Z: S06: (54e89656bc6481ee): Executing operation CoGroupByKey/GroupByKey/Read+CoGroupByKey/GroupByKey/GroupByWindow+CoGroupByKey/ConstructCoGbkResultFn+ParDo(ClickOfPurchase)+PAssert$271/GroupGlobally/Window.Into()+PAssert$271/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$271/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$271/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-17T02:34:08.726Z: (7ebc5834dc525e0c): Cleaning up. [INFO] 2017-02-17T02:34:08.851Z: (7ebc5834dc525100): Stopping worker pool... [INFO] 2017-02-17T02:34:12.564Z: S07: (54e89656bc648084): Executing operation PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-17T02:34:12.582Z: S08: (54e89656bc648fcf): Executing operation PAssert$271/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-17T02:34:12.772Z: S09: (54e89656bc648cb2): 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-17T02:34:12.776Z: S10: (6a208815fa4de651): 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-17T02:34:13.645Z: S19: (a399a053de308a54): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/Flatten.FlattenPCollectionList [INFO] 2017-02-17T02:34:13.382Z: S03: (f949338ff8fd3fe9): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-17T02:34:13.407Z: S04: (f949338ff8fd3872): Executing operation PAssert$273/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-17T02:34:13.599Z: S05: (f949338ff8fd3503): 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-17T02:34:14.911Z: S05: (cdf8c823124c065f): Executing operation CoGroupByKey/GroupByKey/Close [INFO] 2017-02-17T02:34:14.934Z: S06: (cdf8c823124c0f22): Executing operation PAssert$270/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-17T02:34:15.124Z: S07: (cdf8c823124c033d): Executing operation CoGroupByKey/GroupByKey/Read+CoGroupByKey/GroupByKey/GroupByWindow+CoGroupByKey/ConstructCoGbkResultFn+ParDo(CorrelatePurchaseCountForAddressesWithoutNames)+PAssert$270/GroupGlobally/Window.Into()+PAssert$270/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$270/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$270/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$270/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$270/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-17T02:34:13.864Z: S20: (a399a053de308c48): Executing operation PAssert$268/CreateActual/View.AsMap/BatchViewAsMap/View.CreatePCollectionView [INFO] 2017-02-17T02:34:13.982Z: S21: (a399a053de308700): Executing operation PAssert$268/Create.Values/Read(CreateSource)+PAssert$268/WindowToken+PAssert$268/RunChecks [INFO] 2017-02-17T02:34:16.233Z: (5e156953fc648719): Cleaning up. [INFO] 2017-02-17T02:34:16.336Z: (5e156953fc648235): Stopping worker pool... [INFO] 2017-02-17T02:34:20.896Z: S06: (f949338ff8fd3615): Executing operation PAssert$273/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-17T02:34:20.921Z: S07: (f949338ff8fd3e9e): Executing operation PAssert$273/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-17T02:34:21.106Z: S08: (f949338ff8fd3b2f): 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-17T02:34:21.110Z: S09: (c138d28ba1bb17b4): 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-17T02:34:22.379Z: S11: (6a208815fa4de703): Executing operation PAssert$271/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-17T02:34:22.399Z: S12: (6a208815fa4de58b): 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-17T02:34:21.990Z: S08: (cdf8c823124c04c3): Executing operation PAssert$270/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-17T02:34:22.012Z: S09: (cdf8c823124c0d86): Executing operation PAssert$270/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-17T02:34:22.200Z: S10: (cdf8c823124c01a1): 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-17T02:34:22.205Z: S11: (f8a4e55e1a410115): 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-17T02:34:22.680Z: (39a756e782d8ce39): Workers have started successfully. [INFO] 2017-02-17T02:34:22.383Z: S18: (f8d57fc086c1ab7b): Executing operation PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/Flatten.FlattenPCollectionList [INFO] 2017-02-17T02:34:23.163Z: S19: (f8d57fc086c1a857): Executing operation PAssert$269/CreateActual/View.AsMap/BatchViewAsMap/View.CreatePCollectionView [INFO] 2017-02-17T02:34:23.330Z: S20: (f8d57fc086c1a27f): Executing operation PAssert$269/Create.Values/Read(CreateSource)+PAssert$269/WindowToken+PAssert$269/RunChecks [INFO] 2017-02-17T02:34:25.648Z: (69440062a29ae2cc): Workers have started successfully. [INFO] 2017-02-17T02:34:27.551Z: (ce9bd5c79f27bef8): Cleaning up. [INFO] 2017-02-17T02:34:27.661Z: (ce9bd5c79f27b20c): Stopping worker pool... [INFO] 2017-02-17T02:34:28.897Z: (ba66489caa3cf897): Cleaning up. [INFO] 2017-02-17T02:34:29.019Z: (ba66489caa3cffd3): Stopping worker pool... [INFO] 2017-02-17T02:34:31.476Z: S10: (f949338ff8fd313b): Executing operation PAssert$273/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-17T02:34:31.497Z: S11: (f949338ff8fd3543): 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-02-17T02:34:32.695Z: S12: (f8a4e55e1a410433): Executing operation PAssert$270/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-17T02:34:32.718Z: S13: (f8a4e55e1a410aeb): 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-17T02:34:37.934Z: (c235274cc76c8a07): Cleaning up. [INFO] 2017-02-17T02:34:38.040Z: (c235274cc76c8f4b): Stopping worker pool... [INFO] 2017-02-17T02:34:39.191Z: (91b0df91477a4792): Cleaning up. [INFO] 2017-02-17T02:34:39.302Z: (91b0df91477a4b26): Stopping worker pool... [INFO] 2017-02-17T02:34:44.044Z: S03: (2bfb11fc08b15d66): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-17T02:34:44.066Z: S04: (2bfb11fc08b154e5): Executing operation PAssert$275/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-17T02:34:44.254Z: S05: (2bfb11fc08b1569c): 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-17T02:34:46.283Z: S03: (40f3153905461da1): Executing operation GroupByKey/Close [INFO] 2017-02-17T02:34:46.307Z: S04: (40f31539054611ee): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-17T02:34:46.495Z: S05: (40f3153905461f63): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-17T02:34:52.551Z: S06: (2bfb11fc08b1559a): Executing operation PAssert$275/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-17T02:34:52.580Z: S07: (2bfb11fc08b15d19): Executing operation PAssert$275/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-17T02:34:53.069Z: S06: (40f31539054617fd): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-17T02:34:53.095Z: S07: (40f3153905461c4a): Executing operation PAssert$272/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-17T02:34:53.289Z: S08: (40f31539054619bf): 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-17T02:34:52.762Z: S08: (2bfb11fc08b15ed0): 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-17T02:34:52.767Z: S09: (c5a9aee19bf55fb3): 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-17T02:34:59.212Z: (9571810b4a615058): Workers have started successfully. [INFO] 2017-02-17T02:35:01.545Z: (cf846ae1ef38b69): Workers have started successfully. [INFO] 2017-02-17T02:35:00.077Z: S09: (40f3153905461259): Executing operation PAssert$272/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-17T02:35:00.116Z: S10: (40f31539054616a6): Executing operation PAssert$272/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-17T02:35:00.297Z: S11: (40f315390546141b): 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-17T02:35:00.304Z: S12: (f7a601ff26190f36): 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] 2017-02-17T02:35:03.588Z: S10: (2bfb11fc08b15e24): Executing operation PAssert$275/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-17T02:35:03.613Z: S11: (2bfb11fc08b1585c): 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-17T02:35:07.207Z: (818150dcce0949ef): Cleaning up. [INFO] 2017-02-17T02:35:07.312Z: (818150dcce094403): Stopping worker pool... [INFO] 2017-02-17T02:35:08.860Z: (7ebc5834dc525737): Worker pool stopped. [INFO] 2017-02-17T02:35:10.553Z: S13: (40f31539054619d7): Executing operation PAssert$272/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-17T02:35:10.579Z: S14: (40f31539054612ff): 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] Job 2017-02-16_18_31_38-13826024673518753648 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_31_38-13826024673518753648. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-02-17T02:35:13.563Z: (d0a500fc085ef08d): Workers have started successfully. [INFO] 2017-02-17T02:35:14.860Z: (3fdc1626f1062013): Worker pool stopped. [INFO] 2017-02-17T02:35:16.993Z: (23180956464fee46): Cleaning up. [INFO] 2017-02-17T02:35:17.104Z: (23180956464fee72): Stopping worker pool... [INFO] Job 2017-02-16_18_31_36-17469355825087817591 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_31_36-17469355825087817591. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-02-17T02:35:17.266Z: S03: (2afb39f9ca7da16): Executing operation GroupByKey/Close [INFO] 2017-02-17T02:35:17.283Z: S04: (2afb39f9ca7d1c5): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-17T02:35:17.472Z: S05: (2afb39f9ca7d92c): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-17T02:35:19.906Z: S03: (4cf5c4a213260a84): Executing operation GroupByKey/Close [INFO] 2017-02-17T02:35:19.930Z: S04: (4cf5c4a213260541): Executing operation Reshuffle/GroupByKey/Create [INFO] 2017-02-17T02:35:20.115Z: S05: (4cf5c4a2132600a6): Executing operation GroupByKey/Read+GroupByKey/GroupByWindow+Reshuffle/Window.Into()+Reshuffle/GroupByKey/Reify+Reshuffle/GroupByKey/Write [INFO] 2017-02-17T02:35:23.937Z: S06: (2afb39f9ca7d88a): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-17T02:35:23.955Z: S07: (2afb39f9ca7d039): Executing operation PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-17T02:35:24.147Z: S08: (2afb39f9ca7d7a0): 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-17T02:35:26.572Z: S06: (4cf5c4a213260620): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-17T02:35:26.594Z: S07: (4cf5c4a2132600dd): Executing operation PAssert$274/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-17T02:35:26.788Z: S08: (4cf5c4a213260c42): 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] 2017-02-17T02:35:30.738Z: S03: (697db8bcd4c97de7): Executing operation Reshuffle/GroupByKey/Close [INFO] 2017-02-17T02:35:30.774Z: S04: (a36e8dbd8532a655): Executing operation PAssert$277/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-17T02:35:30.980Z: S05: (a36e8dbd8532a86e): 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-17T02:35:31.213Z: S09: (2afb39f9ca7d6fe): Executing operation PAssert$276/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-17T02:35:31.234Z: S10: (2afb39f9ca7dead): Executing operation PAssert$276/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-17T02:35:31.422Z: S11: (2afb39f9ca7d614): 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-17T02:35:31.427Z: S12: (e6b8a9816c672645): 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-17T02:35:34.031Z: S09: (4cf5c4a2132601bc): Executing operation PAssert$274/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-17T02:35:34.047Z: S10: (4cf5c4a213260c79): Executing operation PAssert$274/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-17T02:35:34.237Z: S11: (4cf5c4a2132607de): 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-17T02:35:34.241Z: S12: (40af779830b81be5): 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-17T02:35:37.669Z: (ce9bd5c79f27b05b): Worker pool stopped. [INFO] 2017-02-17T02:35:38.321Z: S06: (a36e8dbd8532a410): Executing operation PAssert$277/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-17T02:35:38.346Z: S07: (a36e8dbd8532a9e1): Executing operation PAssert$277/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-17T02:35:38.532Z: S08: (a36e8dbd8532abfa): 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-17T02:35:38.538Z: S09: (697db8bcd4c977e4): 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-17T02:35:39.025Z: (ba66489caa3cf140): Worker pool stopped. [INFO] Job 2017-02-16_18_31_07-588513465383834444 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_31_07-588513465383834444. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-17T02:35:42.060Z: S13: (e6b8a9816c672bcb): Executing operation PAssert$276/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-17T02:35:42.079Z: S14: (e6b8a9816c672723): 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-17T02:35:44.918Z: S13: (40af779830b81ff7): Executing operation PAssert$274/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-17T02:35:44.938Z: S14: (40af779830b81fff): 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] Job 2017-02-16_18_31_30-7074747492490341518 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_31_30-7074747492490341518. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-17T02:35:49.005Z: S10: (a36e8dbd8532ae66): Executing operation PAssert$277/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-17T02:35:49.038Z: S11: (a36e8dbd8532aaae): 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-17T02:35:48.627Z: (7dbcd7c78e67ffea): Cleaning up. [INFO] 2017-02-17T02:35:48.751Z: (7dbcd7c78e67f79e): Stopping worker pool... [INFO] 2017-02-17T02:35:49.309Z: (91b0df91477a45d5): Worker pool stopped. [INFO] Job 2017-02-16_18_30_52-10257809068630749274 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_30_52-10257809068630749274. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-02-16_18_31_17-8651739932510086783 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_31_17-8651739932510086783. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-17T02:35:53.047Z: (c235274cc76c8f3e): Worker pool stopped. [INFO] 2017-02-17T02:35:53.071Z: (2ca6bce619641931): Cleaning up. [INFO] 2017-02-17T02:35:53.190Z: (2ca6bce619641ee5): Stopping worker pool... [INFO] 2017-02-17T02:35:54.473Z: (d17d10b8526f589): Cleaning up. [INFO] 2017-02-17T02:35:54.558Z: (d17d10b8526fe05): Stopping worker pool... [INFO] Job 2017-02-16_18_31_48-15100235812699157251 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_31_48-15100235812699157251. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-17T02:36:12.320Z: (818150dcce094792): Worker pool stopped. [INFO] Job 2017-02-16_18_32_17-9913332567501113390 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_32_17-9913332567501113390. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-17T02:36:37.112Z: (23180956464fe293): Worker pool stopped. [INFO] Job 2017-02-16_18_31_48-17975802085105442542 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_31_48-17975802085105442542. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-02-16_18_32_51-2492368634703755420 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_32_51-2492368634703755420. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-17T02:36:58.196Z: (2ca6bce619641b2c): Worker pool stopped. [INFO] Job 2017-02-16_18_32_16-17812949288073807016 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_32_16-17812949288073807016. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-17T02:37:09.570Z: (d17d10b8526f462): Worker pool stopped. [INFO] Job 2017-02-16_18_33_07-298650013869963551 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-16_18_33_07-298650013869963551. Found 1 success, 0 failures out of 1 expected assertions. Running org.apache.beam.sdk.io.ReadTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.558 sec - in org.apache.beam.sdk.io.ReadTest Running org.apache.beam.sdk.transforms.join.CoGroupByKeyTest Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 303.364 sec - in org.apache.beam.sdk.transforms.join.CoGroupByKeyTest Running [limit_36] Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2,318.712 sec - in [limit_36] 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: 330.118 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: 225.627 sec - in org.apache.beam.sdk.transforms.windowing.WindowTest Results : Tests run: 212, Failures: 0, Errors: 0, Skipped: 3 [JENKINS] Recording test results 2017-02-17T02:37:18.823 [INFO] 2017-02-17T02:37:18.823 [INFO] --- maven-dependency-plugin:3.0.0:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-02-17T02:37:18.943 [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-17T02:37:22.498 [INFO] ------------------------------------------------------------------------ 2017-02-17T02:37:22.498 [INFO] Reactor Summary: 2017-02-17T02:37:22.498 [INFO] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 24.541 s] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 4.584 s] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 4.742 s] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: SDKs :: Common ...................... SUCCESS [ 1.168 s] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: SDKs :: Common :: Fn API ............ SUCCESS [ 16.681 s] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: SDKs :: Common :: Runner API ........ SUCCESS [ 5.809 s] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 1.259 s] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [02:54 min] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 0.784 s] 2017-02-17T02:37:22.499 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:28 h] 2017-02-17T02:37:22.499 [INFO] ------------------------------------------------------------------------ 2017-02-17T02:37:22.499 [INFO] BUILD SUCCESS 2017-02-17T02:37:22.499 [INFO] ------------------------------------------------------------------------ 2017-02-17T02:37:22.499 [INFO] Total time: 01:32 h 2017-02-17T02:37:22.499 [INFO] Finished at: 2017-02-17T02:37:22+00:00 2017-02-17T02:37:23.619 [INFO] Final Memory: 214M/1753M 2017-02-17T02:37:23.619 [INFO] ------------------------------------------------------------------------ Waiting for Jenkins to finish collecting data channel stopped
