See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4738/display/redirect>
------------------------------------------ [...truncated 22.86 MB...] [INFO] 2018-01-18T02:02:04.267Z: (1c7eb2542bc3e3ed): Unzipping flatten s15 for input s10.10 [INFO] 2018-01-18T02:02:04.283Z: (1c7eb2542bc3eebb): Fusing unzipped copy of PAssert$367/GroupGlobally/GroupDummyAndContents/Reify, through flatten PAssert$367/GroupGlobally/FlattenDummyAndContents, into producer PAssert$367/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2018-01-18T02:02:04.307Z: (1c7eb2542bc3e989): Unzipping flatten s15-u22 for input s17-reify-value0-c20 [INFO] 2018-01-18T02:02:04.330Z: (1c7eb2542bc3e457): Fusing unzipped copy of PAssert$367/GroupGlobally/GroupDummyAndContents/Write, through flatten s15-u22, into producer PAssert$367/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2018-01-18T02:02:04.358Z: (1c7eb2542bc3ef25): Fusing consumer PAssert$367/GetPane/Map into PAssert$367/GroupGlobally/ParDo(Concat) [INFO] 2018-01-18T02:02:04.392Z: (1c7eb2542bc3e9f3): Fusing consumer PAssert$367/VerifyAssertions/ParDo(DefaultConclude) into PAssert$367/RunChecks [INFO] 2018-01-18T02:02:04.413Z: (1c7eb2542bc3e4c1): Fusing consumer PAssert$367/RunChecks into PAssert$367/GetPane/Map [INFO] 2018-01-18T02:02:04.435Z: (1c7eb2542bc3ef8f): Fusing consumer PAssert$367/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$367/GroupGlobally/GroupDummyAndContents/Read [INFO] 2018-01-18T02:02:04.455Z: (1c7eb2542bc3ea5d): Fusing consumer PAssert$367/GroupGlobally/Values/Values/Map into PAssert$367/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2018-01-18T02:02:04.477Z: (1c7eb2542bc3e52b): Fusing consumer PAssert$367/GroupGlobally/ParDo(Concat) into PAssert$367/GroupGlobally/Values/Values/Map [INFO] 2018-01-18T02:02:04.504Z: (1c7eb2542bc3eff9): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) into PAssert$367/GroupGlobally/Window.Into()/Window.Assign [INFO] 2018-01-18T02:02:04.525Z: (1c7eb2542bc3eac7): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2018-01-18T02:02:04.548Z: (1c7eb2542bc3e595): Fusing consumer PAssert$367/GroupGlobally/RewindowActuals/Window.Assign into PAssert$367/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2018-01-18T02:02:04.570Z: (1c7eb2542bc3e063): Fusing consumer KvSwap/KvSwap/Map into Create.Values/Read(CreateSource) [INFO] 2018-01-18T02:02:04.584Z: (1c7eb2542bc3eb31): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$367/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2018-01-18T02:02:04.601Z: (1c7eb2542bc3e5ff): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$367/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) [INFO] 2018-01-18T02:02:04.627Z: (1c7eb2542bc3e0cd): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2018-01-18T02:02:04.645Z: (1c7eb2542bc3eb9b): Fusing consumer PAssert$367/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$367/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2018-01-18T02:02:04.671Z: (1c7eb2542bc3e669): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$367/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2018-01-18T02:02:04.687Z: (1c7eb2542bc3e137): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2018-01-18T02:02:04.713Z: (1c7eb2542bc3ec05): Fusing consumer PAssert$367/GroupGlobally/Window.Into()/Window.Assign into KvSwap/KvSwap/Map [INFO] 2018-01-18T02:02:04.739Z: (1c7eb2542bc3e6d3): Fusing consumer PAssert$367/GroupGlobally/GroupDummyAndContents/Reify into PAssert$367/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2018-01-18T02:02:04.765Z: (1c7eb2542bc3e1a1): Fusing consumer PAssert$367/GroupGlobally/GroupDummyAndContents/Write into PAssert$367/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2018-01-18T02:02:04.782Z: (1c7eb2542bc3ec6f): Fusing consumer PAssert$367/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$367/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2018-01-18T02:02:05.065Z: (efe6da217e0c8888): Executing operation PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2018-01-18T02:02:05.119Z: (dd8a58028b2889de): Starting 1 workers in us-central1-f... [INFO] 2018-01-18T02:02:05.245Z: (7ccbdf4f47d513b6): Executing operation Create.Values/Read(CreateSource)+KvSwap/KvSwap/Map+PAssert$367/GroupGlobally/Window.Into()/Window.Assign+PAssert$367/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$367/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$367/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2018-01-18T02:02:08.057Z: (42080fea8fd4b9e3): Cleaning up. [INFO] 2018-01-18T02:02:08.093Z: (42080fea8fd4bcc8): Stopping worker pool... [INFO] 2018-01-18T02:02:09.599Z: (891867f22ace9e3): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] 2018-01-18T02:02:13.581Z: (f72b2294f3e07c5b): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] Staging files complete: 0 files cached, 132 files newly uploaded [INFO] Adding Create.Values/Read(CreateSource) as step s1 [INFO] Adding KvSwap/KvSwap/Map as step s2 [INFO] Adding PAssert$366/GroupGlobally/Window.Into()/Window.Assign as step s3 [INFO] Adding PAssert$366/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) as step s4 [INFO] Adding PAssert$366/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map as step s5 [INFO] Adding PAssert$366/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign as step s6 [INFO] Adding PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey as step s7 [INFO] Adding PAssert$366/GroupGlobally/GatherAllOutputs/Values/Values/Map as step s8 [INFO] Adding PAssert$366/GroupGlobally/RewindowActuals/Window.Assign as step s9 [INFO] Adding PAssert$366/GroupGlobally/KeyForDummy/AddKeys/Map as step s10 [INFO] Adding PAssert$366/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections as step s11 [INFO] Adding PAssert$366/GroupGlobally/Create.Values/Read(CreateSource) as step s12 [INFO] Adding PAssert$366/GroupGlobally/WindowIntoDummy/Window.Assign as step s13 [INFO] Adding PAssert$366/GroupGlobally/RemoveDummyTriggering/Flatten.PCollections as step s14 [INFO] Adding PAssert$366/GroupGlobally/FlattenDummyAndContents as step s15 [INFO] Adding PAssert$366/GroupGlobally/NeverTrigger/Flatten.PCollections as step s16 [INFO] Adding PAssert$366/GroupGlobally/GroupDummyAndContents as step s17 [INFO] Adding PAssert$366/GroupGlobally/Values/Values/Map as step s18 [INFO] Adding PAssert$366/GroupGlobally/ParDo(Concat) as step s19 [INFO] Adding PAssert$366/GetPane/Map as step s20 [INFO] Adding PAssert$366/RunChecks as step s21 [INFO] Adding PAssert$366/VerifyAssertions/ParDo(DefaultConclude) as step s22 [INFO] Staging pipeline description to gs://temp-storage-for-validates-runner-tests//kvswaptest0testkvswapempty-jenkins-0118020150-d727ec9e/output/results/staging/ [INFO] Uploading <43274 bytes, hash m84ZUfBllEu9Y6rIPPCayA> to gs://temp-storage-for-validates-runner-tests//kvswaptest0testkvswapempty-jenkins-0118020150-d727ec9e/output/results/staging/pipeline-m84ZUfBllEu9Y6rIPPCayA.pb [INFO] To access the Dataflow monitoring console, please navigate to https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2018-01-17_18_02_23-7346735919985983404?project=apache-beam-testing [INFO] To cancel the job using the 'gcloud' tool, run: > gcloud dataflow jobs --project=apache-beam-testing cancel > 2018-01-17_18_02_23-7346735919985983404 [INFO] Running Dataflow job 2018-01-17_18_02_23-7346735919985983404 with 1 expected assertions. [INFO] 2018-01-18T02:02:25.398Z: (891867f22ace3ba): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2018-01-18T02:02:29.360Z: (f72b2294f3e07b98): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2018-01-18T02:02:23.223Z: (65f4d965015df5d0): Autoscaling is enabled for job 2018-01-17_18_02_23-7346735919985983404. The number of workers will be between 1 and 15. [INFO] 2018-01-18T02:02:23.251Z: (65f4d965015dff59): Autoscaling was automatically enabled for job 2018-01-17_18_02_23-7346735919985983404. [INFO] 2018-01-18T02:02:25.610Z: (7906d4b28f0a1e10): Checking required Cloud APIs are enabled. [INFO] 2018-01-18T02:02:29.611Z: (7906d4b28f0a1740): Expanding CoGroupByKey operations into optimizable parts. [INFO] 2018-01-18T02:02:29.650Z: (7906d4b28f0a155d): Expanding GroupByKey operations into optimizable parts. [INFO] 2018-01-18T02:02:29.683Z: (7906d4b28f0a14d3): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns [INFO] 2018-01-18T02:02:29.742Z: (7906d4b28f0a1221): Fusing adjacent ParDo, Read, Write, and Flatten operations [INFO] 2018-01-18T02:02:29.777Z: (7906d4b28f0a1197): Elided trivial flatten [INFO] 2018-01-18T02:02:29.809Z: (7906d4b28f0a110d): Elided trivial flatten [INFO] 2018-01-18T02:02:29.841Z: (7906d4b28f0a1083): Elided trivial flatten [INFO] 2018-01-18T02:02:29.869Z: (7906d4b28f0a1ff9): Fusing consumer PAssert$366/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$366/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2018-01-18T02:02:30.076Z: (7906d4b28f0a1f6f): Unzipping flatten s15 for input s10.10 [INFO] 2018-01-18T02:02:30.106Z: (7906d4b28f0a1ee5): Fusing unzipped copy of PAssert$366/GroupGlobally/GroupDummyAndContents/Reify, through flatten PAssert$366/GroupGlobally/FlattenDummyAndContents, into producer PAssert$366/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2018-01-18T02:02:30.128Z: (7906d4b28f0a1e5b): Fusing consumer PAssert$366/GroupGlobally/GroupDummyAndContents/Reify into PAssert$366/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2018-01-18T02:02:30.162Z: (7906d4b28f0a1dd1): Fusing consumer PAssert$366/GetPane/Map into PAssert$366/GroupGlobally/ParDo(Concat) [INFO] 2018-01-18T02:02:30.180Z: (7906d4b28f0a1d47): Fusing consumer PAssert$366/VerifyAssertions/ParDo(DefaultConclude) into PAssert$366/RunChecks [INFO] 2018-01-18T02:02:30.203Z: (7906d4b28f0a1cbd): Unzipping flatten s15-u22 for input s17-reify-value0-c20 [INFO] 2018-01-18T02:02:30.232Z: (7906d4b28f0a1c33): Fusing unzipped copy of PAssert$366/GroupGlobally/GroupDummyAndContents/Write, through flatten s15-u22, into producer PAssert$366/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2018-01-18T02:02:30.254Z: (7906d4b28f0a1ba9): Fusing consumer PAssert$366/GroupGlobally/GroupDummyAndContents/Write into PAssert$366/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2018-01-18T02:02:30.278Z: (7906d4b28f0a1b1f): Fusing consumer PAssert$366/RunChecks into PAssert$366/GetPane/Map [INFO] 2018-01-18T02:02:30.310Z: (7906d4b28f0a1a95): Fusing consumer PAssert$366/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$366/GroupGlobally/GroupDummyAndContents/Read [INFO] 2018-01-18T02:02:30.343Z: (7906d4b28f0a1a0b): Fusing consumer PAssert$366/GroupGlobally/Values/Values/Map into PAssert$366/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2018-01-18T02:02:30.370Z: (7906d4b28f0a1981): Fusing consumer PAssert$366/GroupGlobally/ParDo(Concat) into PAssert$366/GroupGlobally/Values/Values/Map [INFO] 2018-01-18T02:02:30.400Z: (7906d4b28f0a18f7): Fusing consumer KvSwap/KvSwap/Map into Create.Values/Read(CreateSource) [INFO] 2018-01-18T02:02:30.430Z: (7906d4b28f0a186d): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2018-01-18T02:02:30.457Z: (7906d4b28f0a17e3): Fusing consumer PAssert$366/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$366/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2018-01-18T02:02:30.485Z: (7906d4b28f0a1759): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) into PAssert$366/GroupGlobally/Window.Into()/Window.Assign [INFO] 2018-01-18T02:02:30.508Z: (7906d4b28f0a16cf): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2018-01-18T02:02:30.541Z: (7906d4b28f0a1645): Fusing consumer PAssert$366/GroupGlobally/RewindowActuals/Window.Assign into PAssert$366/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2018-01-18T02:02:30.573Z: (7906d4b28f0a15bb): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$366/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) [INFO] 2018-01-18T02:02:30.606Z: (7906d4b28f0a1531): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$366/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2018-01-18T02:02:30.632Z: (7906d4b28f0a14a7): Fusing consumer PAssert$366/GroupGlobally/Window.Into()/Window.Assign into KvSwap/KvSwap/Map [INFO] 2018-01-18T02:02:30.658Z: (7906d4b28f0a141d): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$366/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2018-01-18T02:02:30.681Z: (7906d4b28f0a1393): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2018-01-18T02:02:30.989Z: (456f22da9c1b749c): Executing operation PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2018-01-18T02:02:31.059Z: (a2fe390c72b79061): Starting 1 workers in us-central1-f... [INFO] 2018-01-18T02:02:31.185Z: (456f22da9c1b79b9): Executing operation Create.Values/Read(CreateSource)+KvSwap/KvSwap/Map+PAssert$366/GroupGlobally/Window.Into()/Window.Assign+PAssert$366/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$366/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$366/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2018-01-18T02:02:37.637Z: (50ee5619d53bab8d): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] 2018-01-18T02:02:38.914Z: (303e22d6cd7ae10e): Cleaning up. [INFO] 2018-01-18T02:02:38.961Z: (303e22d6cd7ae4a7): Stopping worker pool... [INFO] 2018-01-18T02:02:42.789Z: (d64ecdaaf51620a8): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2018-01-18T02:02:42.811Z: (d64ecdaaf5162c12): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2018-01-18T02:02:42.851Z: (ab812fe5d0379903): Worker pool stopped. [INFO] 2018-01-18T02:02:47.727Z: (408a44efcd641f92): Workers have started successfully. [INFO] Job 2018-01-17_17_59_42-7082159316789719207 finished with status DONE. [INFO] Success result for Dataflow job 2018-01-17_17_59_42-7082159316789719207. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2018-01-18T02:02:53.461Z: (50ee5619d53bae0a): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2018-01-18T02:02:53.171Z: (7c6f9ed617d8f44d): Workers have started successfully. [INFO] 2018-01-18T02:02:56.729Z: (bb0e3343ae94127d): Cleaning up. [INFO] 2018-01-18T02:02:56.765Z: (bb0e3343ae941e34): Stopping worker pool... [INFO] 2018-01-18T02:03:06.044Z: (bda53fbee1842edb): Executing operation PAssert$365/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2018-01-18T02:03:06.073Z: (b47a47299ada2624): Executing operation PAssert$364/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2018-01-18T02:03:06.148Z: (bda53fbee1842e53): Executing operation PAssert$365/GroupGlobally/GroupDummyAndContents/Create [INFO] 2018-01-18T02:03:06.199Z: (b47a47299ada2cac): Executing operation PAssert$364/GroupGlobally/GroupDummyAndContents/Create [INFO] 2018-01-18T02:03:06.399Z: (b47a47299ada2da7): Executing operation PAssert$365/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$365/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$365/GroupGlobally/GroupDummyAndContents/Reify+PAssert$365/GroupGlobally/GroupDummyAndContents/Write [INFO] 2018-01-18T02:03:06.419Z: (bda53fbee1842a66): Executing operation PAssert$365/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$365/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$365/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$365/GroupGlobally/RewindowActuals/Window.Assign+PAssert$365/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$365/GroupGlobally/GroupDummyAndContents/Reify+PAssert$365/GroupGlobally/GroupDummyAndContents/Write [INFO] 2018-01-18T02:03:06.454Z: (6373ed5b0721ab71): Executing operation PAssert$364/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$364/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$364/GroupGlobally/GroupDummyAndContents/Reify+PAssert$364/GroupGlobally/GroupDummyAndContents/Write [INFO] 2018-01-18T02:03:06.493Z: (c80e0e62577930f0): Executing operation PAssert$364/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$364/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$364/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$364/GroupGlobally/RewindowActuals/Window.Assign+PAssert$364/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$364/GroupGlobally/GroupDummyAndContents/Reify+PAssert$364/GroupGlobally/GroupDummyAndContents/Write [INFO] 2018-01-18T02:03:13.203Z: (7ccbdf4f47d51c32): Executing operation PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2018-01-18T02:03:13.270Z: (7ccbdf4f47d511da): Executing operation PAssert$367/GroupGlobally/GroupDummyAndContents/Create [INFO] 2018-01-18T02:03:13.408Z: (7ccbdf4f47d51ffe): Executing operation PAssert$367/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$367/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$367/GroupGlobally/GroupDummyAndContents/Reify+PAssert$367/GroupGlobally/GroupDummyAndContents/Write [INFO] 2018-01-18T02:03:13.435Z: (2429e971c1579e7d): Executing operation PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$367/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$367/GroupGlobally/RewindowActuals/Window.Assign+PAssert$367/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$367/GroupGlobally/GroupDummyAndContents/Reify+PAssert$367/GroupGlobally/GroupDummyAndContents/Write [INFO] 2018-01-18T02:03:12.208Z: (2262f07700946698): Workers have started successfully. [INFO] 2018-01-18T02:03:15.762Z: (ec4ce6347a0c79c6): Worker pool stopped. [INFO] 2018-01-18T02:03:17.758Z: (42080fea8fd4bd73): Worker pool stopped. [INFO] 2018-01-18T02:03:23.457Z: (bda53fbee1842f45): Executing operation PAssert$365/GroupGlobally/GroupDummyAndContents/Close [INFO] 2018-01-18T02:03:23.503Z: (bda53fbee18428ce): Executing operation PAssert$365/GroupGlobally/GroupDummyAndContents/Read+PAssert$365/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$365/GroupGlobally/Values/Values/Map+PAssert$365/GroupGlobally/ParDo(Concat)+PAssert$365/GetPane/Map+PAssert$365/RunChecks+PAssert$365/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2018-01-18T02:03:22.633Z: (aae8d271b483aef8): Worker pool stopped. [INFO] Job 2018-01-17_17_59_53-10556277000572892317 finished with status DONE. [WARNING] Dataflow job 2018-01-17_17_59_53-10556277000572892317 did not output a success or failure metric. [INFO] Job 2018-01-17_17_59_28-15981928550028833265 finished with status DONE. [WARNING] Dataflow job 2018-01-17_17_59_28-15981928550028833265 did not output a success or failure metric. [INFO] 2018-01-18T02:03:24.252Z: (2429e971c1579b06): Executing operation PAssert$367/GroupGlobally/GroupDummyAndContents/Close [INFO] 2018-01-18T02:03:24.340Z: (2429e971c15795d5): Executing operation PAssert$367/GroupGlobally/GroupDummyAndContents/Read+PAssert$367/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$367/GroupGlobally/Values/Values/Map+PAssert$367/GroupGlobally/ParDo(Concat)+PAssert$367/GetPane/Map+PAssert$367/RunChecks+PAssert$367/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2018-01-18T02:03:29.694Z: (70d3fb87da888378): Executing operation PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2018-01-18T02:03:29.761Z: (456f22da9c1b7a6d): Executing operation PAssert$366/GroupGlobally/GroupDummyAndContents/Create [INFO] 2018-01-18T02:03:29.893Z: (456f22da9c1b7f12): Executing operation PAssert$366/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$366/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$366/GroupGlobally/GroupDummyAndContents/Reify+PAssert$366/GroupGlobally/GroupDummyAndContents/Write [INFO] 2018-01-18T02:03:29.924Z: (70d3fb87da888e5f): Executing operation PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$366/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$366/GroupGlobally/RewindowActuals/Window.Assign+PAssert$366/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$366/GroupGlobally/GroupDummyAndContents/Reify+PAssert$366/GroupGlobally/GroupDummyAndContents/Write [INFO] 2018-01-18T02:03:30.181Z: (6373ed5b0721a735): Executing operation PAssert$364/GroupGlobally/GroupDummyAndContents/Close [INFO] 2018-01-18T02:03:30.221Z: (bda53fbee18427be): Executing operation PAssert$364/GroupGlobally/GroupDummyAndContents/Read+PAssert$364/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$364/GroupGlobally/Values/Values/Map+PAssert$364/GroupGlobally/ParDo(Concat)+PAssert$364/GetPane/Map+PAssert$364/RunChecks+PAssert$364/VerifyAssertions/ParDo(DefaultConclude) [INFO] Job 2018-01-17_17_59_59-18356151506637511352 finished with status DONE. [WARNING] Dataflow job 2018-01-17_17_59_59-18356151506637511352 did not output a success or failure metric. [INFO] 2018-01-18T02:03:32.676Z: (1c7eb2542bc3e846): Cleaning up. [INFO] 2018-01-18T02:03:32.744Z: (1c7eb2542bc3e8b0): Stopping worker pool... [INFO] 2018-01-18T02:03:33.990Z: (c60fc008843bbb51): Cleaning up. [INFO] 2018-01-18T02:03:34.050Z: (c60fc008843bbf63): Stopping worker pool... [INFO] 2018-01-18T02:03:36.195Z: (456f22da9c1b7fc6): Executing operation PAssert$366/GroupGlobally/GroupDummyAndContents/Close [INFO] 2018-01-18T02:03:36.272Z: (456f22da9c1b742f): Executing operation PAssert$366/GroupGlobally/GroupDummyAndContents/Read+PAssert$366/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$366/GroupGlobally/Values/Values/Map+PAssert$366/GroupGlobally/ParDo(Concat)+PAssert$366/GetPane/Map+PAssert$366/RunChecks+PAssert$366/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2018-01-18T02:03:39.458Z: (f57165adc8177394): Cleaning up. [INFO] 2018-01-18T02:03:39.506Z: (f57165adc81778d7): Stopping worker pool... [INFO] 2018-01-18T02:03:42.961Z: (7906d4b28f0a1efe): Cleaning up. [INFO] 2018-01-18T02:03:43.045Z: (7906d4b28f0a1d60): Stopping worker pool... [INFO] 2018-01-18T02:03:55.073Z: (303e22d6cd7aecde): Worker pool stopped. [INFO] Job 2018-01-17_18_00_00-17268440603430137649 finished with status DONE. [WARNING] Dataflow job 2018-01-17_18_00_00-17268440603430137649 did not output a success or failure metric. [INFO] 2018-01-18T02:04:04.889Z: (bb0e3343ae941fad): Worker pool stopped. [INFO] Job 2018-01-17_18_00_14-8467217504042228249 finished with status DONE. [WARNING] Dataflow job 2018-01-17_18_00_14-8467217504042228249 did not output a success or failure metric. [INFO] 2018-01-18T02:04:51.088Z: (50ee5619d53ba289): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2018-01-18T02:04:51.115Z: (50ee5619d53ba79f): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2018-01-18T02:04:50.581Z: (f72b2294f3e07033): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2018-01-18T02:04:50.606Z: (f72b2294f3e077c9): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2018-01-18T02:04:52.529Z: (891867f22acee73): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2018-01-18T02:04:52.543Z: (891867f22ace6f5): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2018-01-18T02:04:55.845Z: (f57165adc8177c84): Worker pool stopped. [INFO] Job 2018-01-17_18_01_57-15839210254884717841 finished with status DONE. [INFO] Success result for Dataflow job 2018-01-17_18_01_57-15839210254884717841. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2018-01-17_18_01_53-18120739119772613375 finished with status DONE. [INFO] Success result for Dataflow job 2018-01-17_18_01_53-18120739119772613375. Found 2 success, 0 failures out of 2 expected assertions. [INFO] Job 2018-01-17_18_00_24-5789987656680248611 finished with status DONE. [WARNING] Dataflow job 2018-01-17_18_00_24-5789987656680248611 did not output a success or failure metric. [INFO] Job 2018-01-17_18_02_23-7346735919985983404 finished with status DONE. [INFO] Success result for Dataflow job 2018-01-17_18_02_23-7346735919985983404. Found 1 success, 0 failures out of 1 expected assertions. 2018-01-18T02:05:07.484 [INFO] Running org.apache.beam.sdk.transforms.SplittableDoFnTest 2018-01-18T02:05:07.627 [INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 344.77 s - in org.apache.beam.sdk.transforms.SplittableDoFnTest 2018-01-18T02:05:07.628 [INFO] Running org.apache.beam.sdk.transforms.PartitionTest 2018-01-18T02:05:07.661 [INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 194.724 s - in org.apache.beam.sdk.transforms.PartitionTest 2018-01-18T02:05:07.661 [INFO] Running org.apache.beam.sdk.transforms.CombineFnsTest 2018-01-18T02:05:07.668 [INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 277.021 s - in org.apache.beam.sdk.transforms.CombineFnsTest 2018-01-18T02:05:07.668 [INFO] Running org.apache.beam.sdk.values.PDoneTest 2018-01-18T02:05:07.675 [WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 s - in org.apache.beam.sdk.values.PDoneTest 2018-01-18T02:05:07.675 [INFO] Running org.apache.beam.sdk.transforms.KvSwapTest 2018-01-18T02:05:07.736 [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 197.285 s - in org.apache.beam.sdk.transforms.KvSwapTest 2018-01-18T02:05:07.737 [INFO] Running org.apache.beam.sdk.transforms.windowing.WindowingTest 2018-01-18T02:05:07.740 [INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 269.298 s - in org.apache.beam.sdk.transforms.windowing.WindowingTest 2018-01-18T02:05:07.744 [INFO] 2018-01-18T02:05:07.744 [INFO] Results: 2018-01-18T02:05:07.744 [INFO] 2018-01-18T02:05:07.744 [WARNING] Tests run: 259, Failures: 0, Errors: 0, Skipped: 1 2018-01-18T02:05:07.745 [INFO] [JENKINS] Recording test results 2018-01-18T02:05:08.893 [INFO] 2018-01-18T02:05:08.893 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2018-01-18T02:05:09.092 [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 [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled 2018-01-18T02:05:24.610 [INFO] ------------------------------------------------------------------------ 2018-01-18T02:05:24.610 [INFO] Reactor Summary: 2018-01-18T02:05:24.610 [INFO] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 9.007 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 7.995 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Model ............................... SUCCESS [ 1.557 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Model :: Pipeline ................... SUCCESS [ 9.445 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Model :: Job Management ............. SUCCESS [ 6.371 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Model :: Fn Execution ............... SUCCESS [ 7.419 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.184 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 2.296 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [01:48 min] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 2.233 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Runners :: Local Java Core .......... SUCCESS [ 5.709 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [ 13.601 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [ 23.215 s] 2018-01-18T02:05:24.610 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [06:49 min] 2018-01-18T02:05:24.611 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 2.705 s] 2018-01-18T02:05:24.611 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 2.658 s] 2018-01-18T02:05:24.611 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [ 16.014 s] 2018-01-18T02:05:24.611 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 19.062 s] 2018-01-18T02:05:24.611 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [01:57 min] 2018-01-18T02:05:24.611 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:26 h] 2018-01-18T02:05:24.611 [INFO] ------------------------------------------------------------------------ 2018-01-18T02:05:24.611 [INFO] BUILD SUCCESS 2018-01-18T02:05:24.611 [INFO] ------------------------------------------------------------------------ 2018-01-18T02:05:24.611 [INFO] Total time: 01:40 h 2018-01-18T02:05:24.611 [INFO] Finished at: 2018-01-18T02:05:24+00:00 [JENKINS] Archiving disabled 2018-01-18T02:05:26.938 [INFO] Final Memory: 403M/2767M 2018-01-18T02:05:26.939 [INFO] ------------------------------------------------------------------------ channel stopped Not sending mail to unregistered user ni...@google.com