See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/2766/display/redirect>
------------------------------------------ [...truncated 4.14 MB...] [INFO] 2017-04-07T07:04:04.734Z: (e532a1b7fbe1704): Elided trivial flatten [INFO] 2017-04-07T07:04:04.742Z: (e532a1b7fbe1fbe): Unzipping flatten s15 for input s10.10 [INFO] 2017-04-07T07:04:04.745Z: (e532a1b7fbe17fc): Fusing unzipped copy of PAssert$292/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$292/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-04-07T07:04:04.755Z: (e532a1b7fbe18f4): Unzipping flatten s15-u22 for input s17-reify-value0-c20 [INFO] 2017-04-07T07:04:04.758Z: (e532a1b7fbe1132): Fusing unzipped copy of PAssert$292/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$292/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-04-07T07:04:04.760Z: (e532a1b7fbe1970): Fusing consumer PAssert$292/GetPane/Map into PAssert$292/GroupGlobally/ParDo(Concat) [INFO] 2017-04-07T07:04:04.763Z: (e532a1b7fbe11ae): Fusing consumer PAssert$292/RunChecks into PAssert$292/GetPane/Map [INFO] 2017-04-07T07:04:04.765Z: (e532a1b7fbe19ec): Fusing consumer PAssert$292/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$292/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-04-07T07:04:04.767Z: (e532a1b7fbe122a): Fusing consumer PAssert$292/GroupGlobally/Values/Values/Map into PAssert$292/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-04-07T07:04:04.770Z: (e532a1b7fbe1a68): Fusing consumer PAssert$292/GroupGlobally/ParDo(Concat) into PAssert$292/GroupGlobally/Values/Values/Map [INFO] 2017-04-07T07:04:04.772Z: (e532a1b7fbe12a6): Fusing consumer PAssert$292/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$292/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-04-07T07:04:04.774Z: (e532a1b7fbe1ae4): Fusing consumer PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-04-07T07:04:04.776Z: (e532a1b7fbe1322): Fusing consumer PAssert$292/GroupGlobally/RewindowActuals/Window.Assign into PAssert$292/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-04-07T07:04:04.779Z: (e532a1b7fbe1b60): Fusing consumer KvSwap/KvSwap/Map into Create.Values/Read(CreateSource) [INFO] 2017-04-07T07:04:04.781Z: (e532a1b7fbe139e): Fusing consumer PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$292/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-04-07T07:04:04.783Z: (e532a1b7fbe1bdc): Fusing consumer PAssert$292/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$292/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-04-07T07:04:04.785Z: (e532a1b7fbe141a): Fusing consumer PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-04-07T07:04:04.788Z: (e532a1b7fbe1c58): Fusing consumer PAssert$292/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$292/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-04-07T07:04:04.790Z: (e532a1b7fbe1496): Fusing consumer PAssert$292/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$292/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-04-07T07:04:04.793Z: (e532a1b7fbe1cd4): Fusing consumer PAssert$292/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-04-07T07:04:04.796Z: (e532a1b7fbe1512): Fusing consumer PAssert$292/GroupGlobally/Window.Into()/Window.Assign into KvSwap/KvSwap/Map [INFO] 2017-04-07T07:04:04.798Z: (e532a1b7fbe1d50): Fusing consumer PAssert$292/GroupGlobally/GroupDummyAndContents/Reify into PAssert$292/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-04-07T07:04:04.801Z: (e532a1b7fbe158e): Fusing consumer PAssert$292/GroupGlobally/GroupDummyAndContents/Write into PAssert$292/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-04-07T07:04:04.803Z: (e532a1b7fbe1dcc): Fusing consumer PAssert$292/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$292/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-04-07T07:04:04.899Z: (e532a1b7fbe1dca): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-04-07T07:04:04.955Z: (f73bf737ff33b274): Executing operation PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-04-07T07:04:05.161Z: (e86ba125a200747a): Starting 1 workers... [INFO] 2017-04-07T07:04:05.193Z: (f73bf737ff33bac5): Executing operation Create.Values/Read(CreateSource)+KvSwap/KvSwap/Map+PAssert$292/GroupGlobally/Window.Into()/Window.Assign+PAssert$292/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$292/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$292/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-04-07T07:04:05.066Z: (caa763a4ba89aee8): Worker pool stopped. [INFO] Job 2017-04-07_00_01_15-8784036066866572333 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_01_15-8784036066866572333. Found 1 success, 0 failures out of 1 expected assertions. [INFO] PipelineOptions.filesToStage was not specified. Defaulting to files from the classpath: will stage 100 files. Enable logging at DEBUG level to see which files will be staged. [INFO] Executing pipeline on the Dataflow Service, which will have billing implications related to Google Compute Engine usage and other Google Cloud Services. [INFO] Uploading 100 files from PipelineOptions.filesToStage to staging location to prepare for execution. [INFO] Job 2017-04-07_00_00_23-12585188104389824069 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_00_23-12585188104389824069. Found 1 success, 0 failures out of 1 expected assertions. [INFO] PipelineOptions.filesToStage was not specified. Defaulting to files from the classpath: will stage 100 files. Enable logging at DEBUG level to see which files will be staged. [INFO] Executing pipeline on the Dataflow Service, which will have billing implications related to Google Compute Engine usage and other Google Cloud Services. [INFO] Uploading 100 files from PipelineOptions.filesToStage to staging location to prepare for execution. [INFO] 2017-04-07T07:04:14.812Z: (286e536c1fdd60a4): Worker pool stopped. [INFO] Staging files complete: 0 files cached, 100 files newly uploaded [INFO] To access the Dataflow monitoring console, please navigate to https://console.developers.google.com/project/apache-beam-testing/dataflow/job/2017-04-07_00_04_15-782391850621022470 [INFO] To cancel the job using the 'gcloud' tool, run: > gcloud beta dataflow jobs --project=apache-beam-testing cancel > 2017-04-07_00_04_15-782391850621022470 [INFO] Running Dataflow job 2017-04-07_00_04_15-782391850621022470 with 1 expected assertions. [INFO] Staging files complete: 0 files cached, 100 files newly uploaded [INFO] 2017-04-07T07:04:16.094Z: (b4366e8dd58f8978): Worker pool stopped. [INFO] To access the Dataflow monitoring console, please navigate to https://console.developers.google.com/project/apache-beam-testing/dataflow/job/2017-04-07_00_04_17-15714864678814304202 [INFO] To cancel the job using the 'gcloud' tool, run: > gcloud beta dataflow jobs --project=apache-beam-testing cancel > 2017-04-07_00_04_17-15714864678814304202 [INFO] Running Dataflow job 2017-04-07_00_04_17-15714864678814304202 with 1 expected assertions. [INFO] 2017-04-07T07:04:17.060Z: (da166a2a1a0f4656): Autoscaling is enabled for job 2017-04-07_00_04_17-15714864678814304202. The number of workers will be between 1 and 15. [INFO] 2017-04-07T07:04:17.060Z: (da166a2a1a0f4d9c): Autoscaling was automatically enabled for job 2017-04-07_00_04_17-15714864678814304202. [INFO] 2017-04-07T07:04:17.682Z: (ca5d99970d40d259): Worker pool stopped. [INFO] 2017-04-07T07:04:15.530Z: (adb9d3e2b6d3994): Autoscaling was automatically enabled for job 2017-04-07_00_04_15-782391850621022470. [INFO] 2017-04-07T07:04:15.530Z: (adb9d3e2b6d36ba): Autoscaling is enabled for job 2017-04-07_00_04_15-782391850621022470. The number of workers will be between 1 and 15. [INFO] 2017-04-07T07:04:17.053Z: (5bb16f4f22e3be0): Checking required Cloud APIs are enabled. [INFO] 2017-04-07T07:04:18.263Z: (c138a41ea92b2a25): Checking required Cloud APIs are enabled. [INFO] Job 2017-04-07_00_01_17-8233122809847394029 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_01_17-8233122809847394029. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-04-07_00_00_46-3341313669993602486 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_00_46-3341313669993602486. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-04-07_00_01_06-217531254430811653 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_01_06-217531254430811653. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-04-07T07:04:20.021Z: (b2ee983055ae4b52): Executing operation PAssert$291/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-04-07T07:04:20.038Z: (b2ee983055ae4d4f): Executing operation PAssert$291/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-04-07T07:04:20.234Z: (b2ee983055ae4fda): Executing operation PAssert$291/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$291/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$291/GroupGlobally/GroupDummyAndContents/Reify+PAssert$291/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-04-07T07:04:20.239Z: (acda010654e0d3b8): Executing operation PAssert$291/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$291/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$291/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$291/GroupGlobally/RewindowActuals/Window.Assign+PAssert$291/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$291/GroupGlobally/GroupDummyAndContents/Reify+PAssert$291/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-04-07T07:04:22.523Z: (c138a41ea92b2474): Expanding GroupByKey operations into optimizable parts. [INFO] 2017-04-07T07:04:22.526Z: (c138a41ea92b22da): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns [INFO] 2017-04-07T07:04:22.532Z: (c138a41ea92b2e0c): Annotating graph with Autotuner information. [INFO] 2017-04-07T07:04:22.545Z: (c138a41ea92b2ad8): Fusing adjacent ParDo, Read, Write, and Flatten operations [INFO] 2017-04-07T07:04:22.548Z: (c138a41ea92b293e): Elided trivial flatten [INFO] 2017-04-07T07:04:22.550Z: (c138a41ea92b27a4): Elided trivial flatten [INFO] 2017-04-07T07:04:22.552Z: (c138a41ea92b260a): Elided trivial flatten [INFO] 2017-04-07T07:04:22.559Z: (c138a41ea92b213c): Unzipping flatten s16 for input s11.11 [INFO] 2017-04-07T07:04:22.562Z: (c138a41ea92b2fa2): Fusing unzipped copy of PAssert$294/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$294/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-04-07T07:04:22.571Z: (c138a41ea92b293a): Unzipping flatten s16-u22 for input s18-reify-value0-c20 [INFO] 2017-04-07T07:04:22.574Z: (c138a41ea92b27a0): Fusing unzipped copy of PAssert$294/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$294/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-04-07T07:04:22.576Z: (c138a41ea92b2606): Fusing consumer PAssert$294/GroupGlobally/ParDo(Concat) into PAssert$294/GroupGlobally/Values/Values/Map [INFO] 2017-04-07T07:04:22.578Z: (c138a41ea92b246c): Fusing consumer PAssert$294/RunChecks into PAssert$294/GetPane/Map [INFO] 2017-04-07T07:04:22.580Z: (c138a41ea92b22d2): Fusing consumer PAssert$294/GetPane/Map into PAssert$294/GroupGlobally/ParDo(Concat) [INFO] 2017-04-07T07:04:22.583Z: (c138a41ea92b2138): Fusing consumer PAssert$294/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$294/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-04-07T07:04:22.585Z: (c138a41ea92b2f9e): Fusing consumer PAssert$294/GroupGlobally/Values/Values/Map into PAssert$294/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-04-07T07:04:22.588Z: (c138a41ea92b2e04): Fusing consumer PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$294/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-04-07T07:04:22.590Z: (c138a41ea92b2c6a): Fusing consumer PAssert$294/GroupGlobally/Window.Into()/Window.Assign into ParDo(ReifyValueTimestamp) [INFO] 2017-04-07T07:04:22.593Z: (c138a41ea92b2ad0): Fusing consumer PAssert$294/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$294/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-04-07T07:04:22.595Z: (c138a41ea92b2936): Fusing consumer PAssert$294/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-04-07T07:04:22.597Z: (c138a41ea92b279c): Fusing consumer PAssert$294/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$294/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-04-07T07:04:22.600Z: (c138a41ea92b2602): Fusing consumer PAssert$294/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$294/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-04-07T07:04:22.602Z: (c138a41ea92b2468): Fusing consumer PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-04-07T07:04:22.604Z: (c138a41ea92b22ce): Fusing consumer PAssert$294/GroupGlobally/RewindowActuals/Window.Assign into PAssert$294/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-04-07T07:04:22.606Z: (c138a41ea92b2134): Fusing consumer PAssert$294/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$294/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-04-07T07:04:22.609Z: (c138a41ea92b2f9a): Fusing consumer WithTimestamps/AddTimestamps into Create.Values/Read(CreateSource) [INFO] 2017-04-07T07:04:22.611Z: (c138a41ea92b2e00): Fusing consumer PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-04-07T07:04:22.613Z: (c138a41ea92b2c66): Fusing consumer ParDo(ReifyValueTimestamp) into WithTimestamps/AddTimestamps [INFO] 2017-04-07T07:04:22.616Z: (c138a41ea92b2acc): Fusing consumer PAssert$294/GroupGlobally/GroupDummyAndContents/Reify into PAssert$294/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-04-07T07:04:22.618Z: (c138a41ea92b2932): Fusing consumer PAssert$294/GroupGlobally/GroupDummyAndContents/Write into PAssert$294/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-04-07T07:04:22.621Z: (c138a41ea92b2798): Fusing consumer PAssert$294/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$294/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-04-07T07:04:22.702Z: (c138a41ea92b2124): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-04-07T07:04:22.751Z: (9dc47a6dac0bf553): Executing operation PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-04-07T07:04:22.957Z: (ccded2096d88ebab): Starting 1 workers... [INFO] 2017-04-07T07:04:22.981Z: (9dc47a6dac0bf248): Executing operation Create.Values/Read(CreateSource)+WithTimestamps/AddTimestamps+ParDo(ReifyValueTimestamp)+PAssert$294/GroupGlobally/Window.Into()/Window.Assign+PAssert$294/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$294/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$294/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-04-07T07:04:21.284Z: (5bb16f4f22e3533): Expanding GroupByKey operations into optimizable parts. [INFO] 2017-04-07T07:04:21.288Z: (5bb16f4f22e3881): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns [INFO] 2017-04-07T07:04:21.296Z: (5bb16f4f22e326b): Annotating graph with Autotuner information. [INFO] 2017-04-07T07:04:21.308Z: (5bb16f4f22e3907): Fusing adjacent ParDo, Read, Write, and Flatten operations [INFO] 2017-04-07T07:04:21.311Z: (5bb16f4f22e3c55): Elided trivial flatten [INFO] 2017-04-07T07:04:21.314Z: (5bb16f4f22e3fa3): Elided trivial flatten [INFO] 2017-04-07T07:04:21.317Z: (5bb16f4f22e32f1): Elided trivial flatten [INFO] 2017-04-07T07:04:21.320Z: (5bb16f4f22e363f): Fusing consumer AssertElementTimestamps into ParDo(ExtractTimestampedValue) [INFO] 2017-04-07T07:04:21.322Z: (5bb16f4f22e398d): Fusing consumer PAssert$293/GroupGlobally/Window.Into()/Window.Assign into ParDo(ExtractTimestampedValue) [INFO] 2017-04-07T07:04:21.330Z: (5bb16f4f22e3377): Unzipping flatten s15 for input s10.10 [INFO] 2017-04-07T07:04:21.332Z: (5bb16f4f22e36c5): Fusing unzipped copy of PAssert$293/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$293/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-04-07T07:04:21.342Z: (5bb16f4f22e33fd): Unzipping flatten s15-u22 for input s17-reify-value0-c20 [INFO] 2017-04-07T07:04:21.345Z: (5bb16f4f22e374b): Fusing unzipped copy of PAssert$293/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$293/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-04-07T07:04:21.347Z: (5bb16f4f22e3a99): Fusing consumer PAssert$293/GetPane/Map into PAssert$293/GroupGlobally/ParDo(Concat) [INFO] 2017-04-07T07:04:21.350Z: (5bb16f4f22e3de7): Fusing consumer PAssert$293/RunChecks into PAssert$293/GetPane/Map [INFO] 2017-04-07T07:04:21.352Z: (5bb16f4f22e3135): Fusing consumer PAssert$293/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$293/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-04-07T07:04:21.355Z: (5bb16f4f22e3483): Fusing consumer PAssert$293/GroupGlobally/Values/Values/Map into PAssert$293/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-04-07T07:04:21.357Z: (5bb16f4f22e37d1): Fusing consumer PAssert$293/GroupGlobally/ParDo(Concat) into PAssert$293/GroupGlobally/Values/Values/Map [INFO] 2017-04-07T07:04:21.360Z: (5bb16f4f22e3b1f): Fusing consumer PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-04-07T07:04:21.363Z: (5bb16f4f22e3e6d): Fusing consumer PAssert$293/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$293/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-04-07T07:04:21.365Z: (5bb16f4f22e31bb): Fusing consumer PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$293/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-04-07T07:04:21.368Z: (5bb16f4f22e3509): Fusing consumer PAssert$293/GroupGlobally/RewindowActuals/Window.Assign into PAssert$293/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-04-07T07:04:21.371Z: (5bb16f4f22e3857): Fusing consumer PAssert$293/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$293/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-04-07T07:04:21.374Z: (5bb16f4f22e3ba5): Fusing consumer PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-04-07T07:04:21.377Z: (5bb16f4f22e3ef3): Fusing consumer PAssert$293/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$293/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-04-07T07:04:21.380Z: (5bb16f4f22e3241): Fusing consumer PAssert$293/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$293/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-04-07T07:04:21.383Z: (5bb16f4f22e358f): Fusing consumer PAssert$293/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-04-07T07:04:21.385Z: (5bb16f4f22e38dd): Fusing consumer ParDo(ExtractTimestampedValue) into Create.Values/Read(CreateSource) [INFO] 2017-04-07T07:04:21.388Z: (5bb16f4f22e3c2b): Fusing consumer PAssert$293/GroupGlobally/GroupDummyAndContents/Write into PAssert$293/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-04-07T07:04:21.391Z: (5bb16f4f22e3f79): Fusing consumer PAssert$293/GroupGlobally/GroupDummyAndContents/Reify into PAssert$293/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-04-07T07:04:21.393Z: (5bb16f4f22e32c7): Fusing consumer PAssert$293/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$293/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-04-07T07:04:21.485Z: (5bb16f4f22e3323): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-04-07T07:04:21.542Z: (43b30b5ead432728): Executing operation PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-04-07T07:04:21.749Z: (dd9c0261ba2af407): Starting 1 workers... [INFO] 2017-04-07T07:04:21.774Z: (43b30b5ead432379): Executing operation Create.Values/Read(CreateSource)+ParDo(ExtractTimestampedValue)+AssertElementTimestamps+PAssert$293/GroupGlobally/Window.Into()/Window.Assign+PAssert$293/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$293/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$293/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-04-07T07:04:24.425Z: (2902786ab25f6cc0): Worker pool stopped. [INFO] 2017-04-07T07:04:26.679Z: (b2ee983055ae4543): Executing operation PAssert$291/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-04-07T07:04:26.700Z: (b2ee983055ae4265): Executing operation PAssert$291/GroupGlobally/GroupDummyAndContents/Read+PAssert$291/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$291/GroupGlobally/Values/Values/Map+PAssert$291/GroupGlobally/ParDo(Concat)+PAssert$291/GetPane/Map+PAssert$291/RunChecks [INFO] Job 2017-04-07_00_01_10-17224519207880619926 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_01_10-17224519207880619926. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-04-07T07:04:33.462Z: (21641632f2f5dc74): Cleaning up. [INFO] 2017-04-07T07:04:33.468Z: (21641632f2f5dba0): Stopping worker pool... [INFO] 2017-04-07T07:04:57.678Z: (fb825120a8ae13ad): Worker pool stopped. [INFO] 2017-04-07T07:04:58.594Z: (2cea6f3c26817d03): Workers have started successfully. [INFO] Job 2017-04-07_00_01_06-17252217402912778361 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_01_06-17252217402912778361. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-04-07T07:05:07.282Z: (e4aa4423d409ba35): Worker pool stopped. [INFO] Job 2017-04-07_00_01_52-15220117425101995073 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_01_52-15220117425101995073. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-04-07T07:05:16.882Z: (fe4dde30377571b0): Worker pool stopped. [INFO] Job 2017-04-07_00_02_05-17141528750830495442 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_02_05-17141528750830495442. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-04-07T07:05:29.816Z: (f73bf737ff33b990): Executing operation PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-04-07T07:05:29.833Z: (f73bf737ff33b757): Executing operation PAssert$292/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-04-07T07:05:30.027Z: (f73bf737ff33bfa8): Executing operation PAssert$292/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$292/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$292/GroupGlobally/GroupDummyAndContents/Reify+PAssert$292/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-04-07T07:05:30.032Z: (ba69cb5e8429456c): Executing operation PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$292/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$292/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$292/GroupGlobally/RewindowActuals/Window.Assign+PAssert$292/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$292/GroupGlobally/GroupDummyAndContents/Reify+PAssert$292/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-04-07T07:05:38.725Z: (f73bf737ff33be73): Executing operation PAssert$292/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-04-07T07:05:38.747Z: (f73bf737ff33b7f9): Executing operation PAssert$292/GroupGlobally/GroupDummyAndContents/Read+PAssert$292/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$292/GroupGlobally/Values/Values/Map+PAssert$292/GroupGlobally/ParDo(Concat)+PAssert$292/GetPane/Map+PAssert$292/RunChecks [INFO] 2017-04-07T07:05:43.545Z: (e532a1b7fbe1b9b): Cleaning up. [INFO] 2017-04-07T07:05:43.552Z: (e532a1b7fbe1c17): Stopping worker pool... [INFO] 2017-04-07T07:05:48.475Z: (21641632f2f5db01): Worker pool stopped. [INFO] Job 2017-04-07_00_02_57-12108539732349465278 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_02_57-12108539732349465278. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-04-07T07:05:52.565Z: (c98a3ed63a58b9b6): Workers have started successfully. [INFO] 2017-04-07T07:05:52.672Z: (2a9c915d5b69bac7): Workers have started successfully. [INFO] 2017-04-07T07:06:16.790Z: (9dc47a6dac0bff5f): Executing operation PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-04-07T07:06:16.807Z: (9dc47a6dac0bf1e2): Executing operation PAssert$294/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-04-07T07:06:16.998Z: (9dc47a6dac0bfed7): Executing operation PAssert$294/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$294/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$294/GroupGlobally/GroupDummyAndContents/Reify+PAssert$294/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-04-07T07:06:17.002Z: (47a0ba72874b7d4e): Executing operation PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$294/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$294/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$294/GroupGlobally/RewindowActuals/Window.Assign+PAssert$294/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$294/GroupGlobally/GroupDummyAndContents/Reify+PAssert$294/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-04-07T07:06:18.240Z: (43b30b5ead432e44): Executing operation PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-04-07T07:06:18.258Z: (43b30b5ead43280b): Executing operation PAssert$293/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-04-07T07:06:18.453Z: (43b30b5ead43245c): Executing operation PAssert$293/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$293/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$293/GroupGlobally/GroupDummyAndContents/Reify+PAssert$293/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-04-07T07:06:18.459Z: (ba8af1afa3f2b6f4): Executing operation PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$293/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$293/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$293/GroupGlobally/RewindowActuals/Window.Assign+PAssert$293/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$293/GroupGlobally/GroupDummyAndContents/Reify+PAssert$293/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-04-07T07:06:25.526Z: (47a0ba72874b76bf): Executing operation PAssert$294/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-04-07T07:06:25.541Z: (47a0ba72874b7db9): Executing operation PAssert$294/GroupGlobally/GroupDummyAndContents/Read+PAssert$294/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$294/GroupGlobally/Values/Values/Map+PAssert$294/GroupGlobally/ParDo(Concat)+PAssert$294/GetPane/Map+PAssert$294/RunChecks [INFO] 2017-04-07T07:06:30.302Z: (c138a41ea92b2d21): Cleaning up. [INFO] 2017-04-07T07:06:28.064Z: (ba8af1afa3f2b563): Executing operation PAssert$293/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-04-07T07:06:28.083Z: (ba8af1afa3f2bb29): Executing operation PAssert$293/GroupGlobally/GroupDummyAndContents/Read+PAssert$293/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$293/GroupGlobally/Values/Values/Map+PAssert$293/GroupGlobally/ParDo(Concat)+PAssert$293/GetPane/Map+PAssert$293/RunChecks [INFO] 2017-04-07T07:06:30.425Z: (c138a41ea92b29ed): Stopping worker pool... [INFO] 2017-04-07T07:06:31.960Z: (5bb16f4f22e33ec): Cleaning up. [INFO] 2017-04-07T07:06:31.965Z: (5bb16f4f22e3a88): Stopping worker pool... [INFO] 2017-04-07T07:06:58.567Z: (e532a1b7fbe1874): Worker pool stopped. [INFO] Job 2017-04-07_00_03_59-2921459075063358796 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_03_59-2921459075063358796. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-04-07T07:07:50.432Z: (c138a41ea92b2f86): Worker pool stopped. [INFO] 2017-04-07T07:07:51.973Z: (5bb16f4f22e377d): Worker pool stopped. [INFO] Job 2017-04-07_00_04_17-15714864678814304202 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_04_17-15714864678814304202. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-04-07_00_04_15-782391850621022470 finished with status DONE. [INFO] Found result while running Dataflow job 2017-04-07_00_04_15-782391850621022470. Found 1 success, 0 failures out of 1 expected assertions. Running org.apache.beam.sdk.transforms.ParDoTest Tests run: 33, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 664.923 sec - in org.apache.beam.sdk.transforms.ParDoTest Running org.apache.beam.sdk.transforms.CountTest Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 242.607 sec - in org.apache.beam.sdk.transforms.CountTest Running org.apache.beam.sdk.transforms.DistinctTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 248.581 sec - in org.apache.beam.sdk.transforms.DistinctTest Running org.apache.beam.sdk.util.ReifyTimestampsTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 228.96 sec - in org.apache.beam.sdk.util.ReifyTimestampsTest 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.KvSwapTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 249.685 sec - in org.apache.beam.sdk.transforms.KvSwapTest Results : Tests run: 232, Failures: 0, Errors: 0, Skipped: 3 [JENKINS] Recording test results 2017-04-07T07:08:00.375 [INFO] 2017-04-07T07:08:00.375 [INFO] --- maven-dependency-plugin:3.0.0:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-04-07T07:08:00.441 [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-04-07T07:08:04.041 [INFO] ------------------------------------------------------------------------ 2017-04-07T07:08:04.042 [INFO] Reactor Summary: 2017-04-07T07:08:04.042 [INFO] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 19.613 s] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 11.218 s] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 1.997 s] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: SDKs :: Common ...................... SUCCESS [ 1.649 s] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: SDKs :: Common :: Fn API ............ SUCCESS [ 12.213 s] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: SDKs :: Common :: Runner API ........ SUCCESS [ 6.340 s] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 4.337 s] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [01:54 min] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 1.613 s] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: Runners :: Core Java Construction ... SUCCESS [ 10.115 s] 2017-04-07T07:08:04.042 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:11 h] 2017-04-07T07:08:04.042 [INFO] ------------------------------------------------------------------------ 2017-04-07T07:08:04.042 [INFO] BUILD SUCCESS 2017-04-07T07:08:04.042 [INFO] ------------------------------------------------------------------------ 2017-04-07T07:08:04.042 [INFO] Total time: 01:17 h 2017-04-07T07:08:04.042 [INFO] Finished at: 2017-04-07T07:08:04+00:00 2017-04-07T07:08:04.676 [INFO] Final Memory: 215M/1706M 2017-04-07T07:08:04.676 [INFO] ------------------------------------------------------------------------ Waiting for Jenkins to finish collecting data channel stopped
