See <https://builds.apache.org/job/beam_PostCommit_Java_RunnableOnService_Dataflow/2288/changes>
Changes: [jesse] Changed name of ToString.of() to ToString.elements(). [klk] Correct Javadoc on accessing windows in DoFn ------------------------------------------ [...truncated 25886 lines...] [INFO] 2017-02-14T07:03:15.733Z: (e87f0e1c8888c9ed): Unzipping flatten s15-u22-u27 for input s17-reify-value1-c25 [INFO] 2017-02-14T07:03:15.735Z: (e87f0e1c8888c2ef): Fusing unzipped copy of PAssert$271/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$271/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-02-14T07:03:15.738Z: (e87f0e1c8888cbf1): Fusing consumer PAssert$271/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$271/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-02-14T07:03:15.740Z: (e87f0e1c8888c4f3): Fusing consumer PAssert$271/GroupGlobally/ParDo(Concat) into PAssert$271/GroupGlobally/Values/Values/Map [INFO] 2017-02-14T07:03:15.742Z: (e87f0e1c8888cdf5): Fusing consumer PAssert$271/GetPane/Map into PAssert$271/GroupGlobally/ParDo(Concat) [INFO] 2017-02-14T07:03:15.744Z: (e87f0e1c8888c6f7): Fusing consumer PAssert$271/GroupGlobally/Values/Values/Map into PAssert$271/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-02-14T07:03:15.747Z: (e87f0e1c8888cff9): Fusing consumer PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-02-14T07:03:15.749Z: (e87f0e1c8888c8fb): Fusing consumer PAssert$271/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$271/GroupGlobally/Window.Into() [INFO] 2017-02-14T07:03:15.751Z: (e87f0e1c8888c1fd): Fusing consumer PAssert$271/GroupGlobally/RemoveActualsTriggering/Identity into PAssert$271/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-02-14T07:03:15.753Z: (e87f0e1c8888caff): Fusing consumer PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$271/GroupGlobally/GatherAllOutputs/Window.Into() [INFO] 2017-02-14T07:03:15.756Z: (e87f0e1c8888c401): Fusing consumer PAssert$271/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$271/GroupGlobally/RewindowActuals [INFO] 2017-02-14T07:03:15.758Z: (e87f0e1c8888cd03): Fusing consumer PAssert$271/GroupGlobally/GatherAllOutputs/Window.Into() into PAssert$271/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-02-14T07:03:15.760Z: (e87f0e1c8888c605): Fusing consumer PAssert$271/GroupGlobally/RewindowActuals into PAssert$271/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-02-14T07:03:15.763Z: (e87f0e1c8888cf07): Fusing consumer PAssert$271/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-02-14T07:03:15.765Z: (e87f0e1c8888c809): Fusing consumer PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-02-14T07:03:15.768Z: (e87f0e1c8888c10b): Fusing consumer KvSwap/KvSwap/Map into Create.Values/Read(CreateSource) [INFO] 2017-02-14T07:03:15.770Z: (e87f0e1c8888ca0d): Fusing consumer PAssert$271/GroupGlobally/Window.Into() into KvSwap/KvSwap/Map [INFO] 2017-02-14T07:03:15.772Z: (e87f0e1c8888c30f): Fusing consumer PAssert$271/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$271/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-02-14T07:03:15.774Z: (e87f0e1c8888cc11): Fusing consumer PAssert$271/GroupGlobally/NeverTrigger/Identity into PAssert$271/GroupGlobally/RemoveDummyTriggering/Identity [INFO] 2017-02-14T07:03:15.777Z: (e87f0e1c8888c513): Fusing consumer PAssert$271/GroupGlobally/GroupDummyAndContents/Write into PAssert$271/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-02-14T07:03:15.779Z: (e87f0e1c8888ce15): Fusing consumer PAssert$271/GroupGlobally/GroupDummyAndContents/Reify into PAssert$271/GroupGlobally/NeverTrigger/Identity [INFO] 2017-02-14T07:03:15.781Z: (e87f0e1c8888c717): Fusing consumer PAssert$271/GroupGlobally/WindowIntoDummy into PAssert$271/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-02-14T07:03:15.783Z: (e87f0e1c8888c019): Fusing consumer PAssert$271/GroupGlobally/RemoveDummyTriggering/Identity into PAssert$271/GroupGlobally/WindowIntoDummy [INFO] 2017-02-14T07:03:15.869Z: (e87f0e1c8888cd63): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-02-14T07:03:15.917Z: S01: (b1ca253ddff49829): Executing operation PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-14T07:03:16.123Z: (ab210bac8153e164): Starting 1 workers... [INFO] 2017-02-14T07:03:16.147Z: S02: (b1ca253ddff492e8): Executing operation Create.Values/Read(CreateSource)+KvSwap/KvSwap/Map+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-14T07:03:15.846Z: (1b2d5d60055ef6af): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:18.147Z: (1b2d5d60055eff71): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:18.193Z: (507ffed0fb4ef4ce): Cleaning up. [INFO] 2017-02-14T07:03:18.300Z: (507ffed0fb4efca2): Stopping worker pool... [INFO] 2017-02-14T07:03:19.883Z: (1b2d5d60055ef833): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:22.188Z: (1b2d5d60055ef0f5): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:23.967Z: (9928ad21f3846894): Worker pool stopped. [INFO] 2017-02-14T07:03:24.250Z: (1b2d5d60055ef9b7): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:26.100Z: (1b2d5d60055ef279): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:27.322Z: (1b2d5d60055efb3b): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] Job 2017-02-13_23_00_20-8057115994944702790 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_00_20-8057115994944702790. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-02-14T07:03:29.653Z: (1b2d5d60055ef3fd): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:32.286Z: (1b2d5d60055efcbf): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:35.174Z: (1b2d5d60055ef581): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:37.944Z: (1b2d5d60055efe43): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:39.072Z: (1b2d5d60055ef705): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:41.112Z: (1b2d5d60055effc7): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:42.674Z: (1b2d5d60055ef889): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:45.445Z: (1b2d5d60055ef14b): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:47.458Z: (1b2d5d60055efa0d): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:49.095Z: (1b2d5d60055ef2cf): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:50.373Z: (90309869714dc1f5): Workers have started successfully. [INFO] 2017-02-14T07:03:48.975Z: (519f1185a223ad4a): Worker pool stopped. [INFO] 2017-02-14T07:03:51.383Z: (1b2d5d60055efb91): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] Job 2017-02-13_23_00_59-17294207624305211845 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_00_59-17294207624305211845. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-14T07:03:53.205Z: (1b2d5d60055ef453): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:53.709Z: (cbb7263587cd7529): Worker pool stopped. [INFO] 2017-02-14T07:03:55.152Z: (1b2d5d60055efd15): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:03:57.987Z: (1b2d5d60055ef5d7): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] Job 2017-02-13_23_00_59-9927990472887253755 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_00_59-9927990472887253755. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-14T07:03:59.117Z: (76219ec137c0f877): Workers have started successfully. [INFO] 2017-02-14T07:03:59.159Z: (1b2d5d60055efe99): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:00.865Z: (1b2d5d60055ef75b): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:02.865Z: (1b2d5d60055ef01d): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:05.331Z: (1b2d5d60055ef8df): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:08.340Z: (1b2d5d60055ef1a1): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:10.391Z: (1b2d5d60055efa63): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:11.482Z: (1b2d5d60055ef325): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:13.018Z: S04: (135797137e4f7bb2): Executing operation PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-14T07:04:13.022Z: S10: (a750ee5211a9c37d): Executing operation PAssert$265/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-14T07:04:13.224Z: S06: (a750ee5211a9c9f7): Executing operation PAssert$266/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$266/GroupGlobally/WindowIntoDummy+PAssert$266/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$266/GroupGlobally/NeverTrigger/Identity+PAssert$266/GroupGlobally/GroupDummyAndContents/Reify+PAssert$266/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:13.230Z: S07: (135797137e4f7828): Executing operation PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$266/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$266/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$266/GroupGlobally/RewindowActuals+PAssert$266/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$266/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$266/GroupGlobally/NeverTrigger/Identity+PAssert$266/GroupGlobally/GroupDummyAndContents/Reify+PAssert$266/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:13.236Z: S12: (4b0b212d323b45f7): Executing operation PAssert$265/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$265/GroupGlobally/WindowIntoDummy+PAssert$265/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$265/GroupGlobally/NeverTrigger/Identity+PAssert$265/GroupGlobally/GroupDummyAndContents/Reify+PAssert$265/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:13.242Z: S13: (3f73fbc65bc8a897): Executing operation PAssert$265/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$265/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$265/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$265/GroupGlobally/RewindowActuals+PAssert$265/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$265/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$265/GroupGlobally/NeverTrigger/Identity+PAssert$265/GroupGlobally/GroupDummyAndContents/Reify+PAssert$265/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:13.744Z: (1b2d5d60055efbe7): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:15.536Z: (c5f1fdbd2ea1cc6f): Workers have started successfully. [INFO] 2017-02-14T07:04:14.714Z: (8bd3401713b3a830): Workers have started successfully. [INFO] 2017-02-14T07:04:15.544Z: (1b2d5d60055ef4a9): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:17.596Z: (1b2d5d60055efd6b): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:19.838Z: (4dbd2fa939b2cf3a): Workers have started successfully. [INFO] 2017-02-14T07:04:20.504Z: (9f4ce95673a63ae7): Workers have started successfully. [INFO] 2017-02-14T07:04:20.499Z: (1b2d5d60055ef62d): Cancel request is committed for workflow job: 2017-02-13_23_00_45-1065426541607178513. [INFO] 2017-02-14T07:04:21.377Z: (4c7311adae928628): Worker pool stopped. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [WARNING] Request failed with code 400, will NOT retry: https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/jobs/2017-02-13_23_00_45-1065426541607178513 [WARNING] Failed to cancel the job, please go to the Developers Console to cancel it manually: https://console.developers.google.com/project/apache-beam-testing/dataflow/job/2017-02-13_23_00_45-1065426541607178513 [INFO] 2017-02-14T07:04:22.895Z: (5e3dfec3c07c20cf): Workflow modification failed. Causes: (4fe360b95c453044): Cannot perform operation 'cancel' on Job: 2017-02-13_23_00_45-1065426541607178513. Job has terminated. [INFO] Cancelling Dataflow job 2017-02-13_23_00_45-1065426541607178513 [WARNING] Request failed with code 400, will NOT retry: https://dataflow.googleapis.com/v1b3/projects/apache-beam-testing/jobs/2017-02-13_23_00_45-1065426541607178513 [WARNING] Job is already terminated. State is CANCELLED [INFO] Job 2017-02-13_23_00_45-1065426541607178513 finished with status CANCELLED. [INFO] The pipeline failed [INFO] 2017-02-14T07:04:27.174Z: S03: (14746db1c48cf5f4): Executing operation Distinct.WithRepresentativeValues/Combine.perKey(Anonymous)/GroupByKey/Close [INFO] 2017-02-14T07:04:27.197Z: S04: (14746db1c48cfa97): Executing operation PAssert$267/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-14T07:04:27.387Z: S05: (14746db1c48cf192): Executing operation Distinct.WithRepresentativeValues/Combine.perKey(Anonymous)/GroupByKey/Read+Distinct.WithRepresentativeValues/Combine.perKey(Anonymous)/Combine.GroupedValues+Distinct.WithRepresentativeValues/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract+Distinct.WithRepresentativeValues/Values/Values/Map+PAssert$267/GroupGlobally/Window.Into()+PAssert$267/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$267/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$267/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$267/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$267/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-14T07:04:28.673Z: S08: (135797137e4f7966): Executing operation PAssert$266/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-14T07:04:28.701Z: S09: (135797137e4f749e): Executing operation PAssert$266/GroupGlobally/GroupDummyAndContents/Read+PAssert$266/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$266/GroupGlobally/Values/Values/Map+PAssert$266/GroupGlobally/ParDo(Concat)+PAssert$266/GetPane/Map+PAssert$266/RunChecks [INFO] 2017-02-14T07:04:31.242Z: S06: (14746db1c48cfad8): Executing operation PAssert$267/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-14T07:04:31.263Z: S07: (14746db1c48cff7b): Executing operation PAssert$267/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-14T07:04:31.452Z: S08: (14746db1c48cf676): Executing operation PAssert$267/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$267/GroupGlobally/WindowIntoDummy+PAssert$267/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$267/GroupGlobally/NeverTrigger/Identity+PAssert$267/GroupGlobally/GroupDummyAndContents/Reify+PAssert$267/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:31.458Z: S09: (8aa34edc8094821a): Executing operation PAssert$267/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$267/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$267/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$267/GroupGlobally/RewindowActuals+PAssert$267/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$267/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$267/GroupGlobally/NeverTrigger/Identity+PAssert$267/GroupGlobally/GroupDummyAndContents/Reify+PAssert$267/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:33.309Z: (507ffed0fb4ef681): Worker pool stopped. [INFO] 2017-02-14T07:04:34.219Z: S14: (3f73fbc65bc8aea9): Executing operation PAssert$265/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-14T07:04:34.246Z: S15: (3f73fbc65bc8a6b1): Executing operation PAssert$265/GroupGlobally/GroupDummyAndContents/Read+PAssert$265/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$265/GroupGlobally/Values/Values/Map+PAssert$265/GroupGlobally/ParDo(Concat)+PAssert$265/GetPane/Map+PAssert$265/RunChecks [INFO] 2017-02-14T07:04:35.655Z: S04: (dafb87ccbfa03fb7): Executing operation PAssert$269/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-14T07:04:35.839Z: S05: (dafb87ccbfa03b3c): Executing operation Distinct/Combine.perKey(Anonymous)/GroupByKey/Read+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract+Distinct/Keys/Keys/Map+PAssert$269/GroupGlobally/Window.Into()+PAssert$269/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$269/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$269/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$269/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$269/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-14T07:04:37.772Z: (274f6c340db82ede): Cleaning up. [INFO] Job 2017-02-13_23_00_43-17119511884451278402 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_00_43-17119511884451278402. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-02-14T07:04:36.982Z: S03: (48dabe3996bb04bd): Executing operation PAssert$270/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-14T07:04:37.003Z: S04: (48dabe3996bb0b8a): Executing operation PAssert$270/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-14T07:04:37.200Z: S05: (48dabe3996bb0f7f): Executing operation PAssert$270/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$270/GroupGlobally/WindowIntoDummy+PAssert$270/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$270/GroupGlobally/NeverTrigger/Identity+PAssert$270/GroupGlobally/GroupDummyAndContents/Reify+PAssert$270/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:37.207Z: S06: (17da44cb9ee301e3): 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/Identity+PAssert$270/GroupGlobally/NeverTrigger/Identity+PAssert$270/GroupGlobally/GroupDummyAndContents/Reify+PAssert$270/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:37.873Z: (274f6c340db82c5a): Stopping worker pool... [INFO] 2017-02-14T07:04:38.903Z: S03: (97224df5cffb55c2): Executing operation Distinct/Combine.perKey(Anonymous)/GroupByKey/Close [INFO] 2017-02-14T07:04:38.923Z: S04: (97224df5cffb5359): Executing operation PAssert$268/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-02-14T07:04:39.110Z: S05: (97224df5cffb55e8): Executing operation Distinct/Combine.perKey(Anonymous)/GroupByKey/Read+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues+Distinct/Combine.perKey(Anonymous)/Combine.GroupedValues/Extract+Distinct/Keys/Keys/Map+PAssert$268/GroupGlobally/Window.Into()+PAssert$268/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$268/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$268/GroupGlobally/GatherAllOutputs/Window.Into()+PAssert$268/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$268/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-02-14T07:04:38.088Z: S06: (dafb87ccbfa03ef6): Executing operation PAssert$269/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-14T07:04:38.119Z: S07: (dafb87ccbfa038d3): Executing operation PAssert$269/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-14T07:04:38.297Z: S08: (dafb87ccbfa03458): Executing operation PAssert$269/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$269/GroupGlobally/WindowIntoDummy+PAssert$269/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$269/GroupGlobally/NeverTrigger/Identity+PAssert$269/GroupGlobally/GroupDummyAndContents/Reify+PAssert$269/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:38.303Z: S09: (53d8b8075526e18d): Executing operation PAssert$269/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$269/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$269/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$269/GroupGlobally/RewindowActuals+PAssert$269/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$269/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$269/GroupGlobally/NeverTrigger/Identity+PAssert$269/GroupGlobally/GroupDummyAndContents/Reify+PAssert$269/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:40.229Z: S10: (14746db1c48cf1fa): Executing operation PAssert$267/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-14T07:04:40.252Z: S11: (14746db1c48cf452): Executing operation PAssert$267/GroupGlobally/GroupDummyAndContents/Read+PAssert$267/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$267/GroupGlobally/Values/Values/Map+PAssert$267/GroupGlobally/ParDo(Concat)+PAssert$267/GetPane/Map+PAssert$267/RunChecks [INFO] 2017-02-14T07:04:41.173Z: S10: (53d8b8075526e18b): Executing operation PAssert$269/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-14T07:04:41.195Z: S11: (53d8b8075526efc3): Executing operation PAssert$269/GroupGlobally/GroupDummyAndContents/Read+PAssert$269/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$269/GroupGlobally/Values/Values/Map+PAssert$269/GroupGlobally/ParDo(Concat)+PAssert$269/GetPane/Map+PAssert$269/RunChecks [INFO] 2017-02-14T07:04:42.341Z: S07: (17da44cb9ee30495): Executing operation PAssert$270/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-14T07:04:42.364Z: S08: (17da44cb9ee30b1d): 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-14T07:04:41.918Z: S03: (b1ca253ddff4989c): Executing operation PAssert$271/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-14T07:04:41.937Z: S04: (b1ca253ddff494e3): Executing operation PAssert$271/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-14T07:04:42.110Z: S05: (b1ca253ddff49fa2): Executing operation PAssert$271/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$271/GroupGlobally/WindowIntoDummy+PAssert$271/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$271/GroupGlobally/NeverTrigger/Identity+PAssert$271/GroupGlobally/GroupDummyAndContents/Reify+PAssert$271/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:42.114Z: S06: (b2fa54e3ce157667): 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/Identity+PAssert$271/GroupGlobally/NeverTrigger/Identity+PAssert$271/GroupGlobally/GroupDummyAndContents/Reify+PAssert$271/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:45.017Z: (d9557ea052ec5e64): Cleaning up. [INFO] 2017-02-14T07:04:45.131Z: (d9557ea052ec5e58): Stopping worker pool... [INFO] 2017-02-14T07:04:44.271Z: S06: (97224df5cffb5116): Executing operation PAssert$268/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-02-14T07:04:44.291Z: S07: (97224df5cffb5ead): Executing operation PAssert$268/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-02-14T07:04:44.480Z: S08: (97224df5cffb513c): Executing operation PAssert$268/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$268/GroupGlobally/WindowIntoDummy+PAssert$268/GroupGlobally/RemoveDummyTriggering/Identity+PAssert$268/GroupGlobally/NeverTrigger/Identity+PAssert$268/GroupGlobally/GroupDummyAndContents/Reify+PAssert$268/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:44.485Z: S09: (d1bcae1ceef2c5e): Executing operation PAssert$268/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$268/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$268/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$268/GroupGlobally/RewindowActuals+PAssert$268/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$268/GroupGlobally/RemoveActualsTriggering/Identity+PAssert$268/GroupGlobally/NeverTrigger/Identity+PAssert$268/GroupGlobally/GroupDummyAndContents/Reify+PAssert$268/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-02-14T07:04:46.442Z: (952a660bbbbe4699): Cleaning up. [INFO] 2017-02-14T07:04:46.557Z: (952a660bbbbe4185): Stopping worker pool... [INFO] 2017-02-14T07:04:47.774Z: (5f80b5246db29076): Cleaning up. [INFO] 2017-02-14T07:04:47.886Z: (5f80b5246db29fea): Stopping worker pool... [INFO] 2017-02-14T07:04:51.062Z: S07: (b1ca253ddff49556): Executing operation PAssert$271/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-14T07:04:51.082Z: S08: (b1ca253ddff493ce): 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-14T07:04:54.713Z: (e87f0e1c8888caf6): Stopping worker pool... [INFO] 2017-02-14T07:04:52.767Z: S10: (97224df5cffb58b0): Executing operation PAssert$268/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-02-14T07:04:52.788Z: S11: (97224df5cffb5da8): Executing operation PAssert$268/GroupGlobally/GroupDummyAndContents/Read+PAssert$268/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$268/GroupGlobally/Values/Values/Map+PAssert$268/GroupGlobally/ParDo(Concat)+PAssert$268/GetPane/Map+PAssert$268/RunChecks [INFO] 2017-02-14T07:04:57.786Z: (54af271f1ac28c01): Cleaning up. [INFO] 2017-02-14T07:04:57.792Z: (54af271f1ac28c4d): Stopping worker pool... [INFO] 2017-02-14T07:05:57.882Z: (274f6c340db82677): Worker pool stopped. [INFO] 2017-02-14T07:06:01.566Z: (952a660bbbbe49b6): Worker pool stopped. [INFO] Job 2017-02-13_23_02_31-3755622972828173426 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_02_31-3755622972828173426. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-02-14T07:06:05.138Z: (d9557ea052ec5e4f): Worker pool stopped. [INFO] Job 2017-02-13_23_03_05-17765148877691951997 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_03_05-17765148877691951997. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-14T07:06:07.798Z: (54af271f1ac28c86): Worker pool stopped. [INFO] Job 2017-02-13_23_02_44-2271001789017240866 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_02_44-2271001789017240866. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-14T07:06:12.894Z: (5f80b5246db29b81): Worker pool stopped. [INFO] Job 2017-02-13_23_02_58-2702583005931274033 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_02_58-2702583005931274033. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-02-14T07:06:14.719Z: (e87f0e1c8888c079): Worker pool stopped. [INFO] Job 2017-02-13_23_03_00-17722203259231622290 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_03_00-17722203259231622290. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-02-13_23_03_10-18011614517441402363 finished with status DONE. [INFO] Found result while running Dataflow job 2017-02-13_23_03_10-18011614517441402363. Found 1 success, 0 failures out of 1 expected assertions. Running org.apache.beam.sdk.transforms.PartitionTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 213.498 sec - in org.apache.beam.sdk.transforms.PartitionTest Running org.apache.beam.sdk.transforms.DistinctTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 216.446 sec - in org.apache.beam.sdk.transforms.DistinctTest Running org.apache.beam.sdk.testing.PAssertTest Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 386.54 sec - in org.apache.beam.sdk.testing.PAssertTest 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: 198.064 sec - in org.apache.beam.sdk.transforms.KvSwapTest Running org.apache.beam.sdk.transforms.ValuesTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 182.224 sec - in org.apache.beam.sdk.transforms.ValuesTest Results : Tests run: 190, Failures: 0, Errors: 0, Skipped: 3 [JENKINS] Recording test results 2017-02-14T07:06:25.778 [INFO] 2017-02-14T07:06:25.778 [INFO] --- maven-dependency-plugin:3.0.0:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-02-14T07:06:25.910 [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 2017-02-14T07:06:30.265 [INFO] ------------------------------------------------------------------------ 2017-02-14T07:06:30.266 [INFO] Reactor Summary: 2017-02-14T07:06:30.266 [INFO] 2017-02-14T07:06:30.266 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 15.685 s] 2017-02-14T07:06:30.266 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 3.373 s] 2017-02-14T07:06:30.266 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.081 s] 2017-02-14T07:06:30.266 [INFO] Apache Beam :: SDKs :: Common ...................... SUCCESS [ 0.762 s] 2017-02-14T07:06:30.266 [INFO] Apache Beam :: SDKs :: Common :: Fn API ............ SUCCESS [ 10.014 s] 2017-02-14T07:06:30.266 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 0.881 s] 2017-02-14T07:06:30.266 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [01:51 min] 2017-02-14T07:06:30.266 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 0.958 s] 2017-02-14T07:06:30.266 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:06 h] 2017-02-14T07:06:30.266 [INFO] ------------------------------------------------------------------------ 2017-02-14T07:06:30.266 [INFO] BUILD SUCCESS 2017-02-14T07:06:30.266 [INFO] ------------------------------------------------------------------------ 2017-02-14T07:06:30.266 [INFO] Total time: 01:09 h 2017-02-14T07:06:30.266 [INFO] Finished at: 2017-02-14T07:06:30+00:00 2017-02-14T07:06:31.906 [INFO] Final Memory: 230M/1445M 2017-02-14T07:06:31.906 [INFO] ------------------------------------------------------------------------ Waiting for Jenkins to finish collecting data channel stopped
