See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4569/display/redirect?page=changes>
Changes: [dariusz.aniszewski] FIX: remove overriding Google project in file-based IOs performance ------------------------------------------ [...truncated 22.91 MB...] [INFO] 2017-12-20T18:29:31.971Z: (6c901070be48f26c): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues into ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read [INFO] 2017-12-20T18:29:31.982Z: (6c901070be48fe6a): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write into ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify [INFO] 2017-12-20T18:29:31.993Z: (6c901070be48fa68): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial into ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map [INFO] 2017-12-20T18:29:32.003Z: (6c901070be48f666): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow) into ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read [INFO] 2017-12-20T18:29:32.013Z: (6c901070be48f264): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract into ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues [INFO] 2017-12-20T18:29:32.022Z: (6c901070be48fe62): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map into ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract [INFO] 2017-12-20T18:29:32.036Z: (6c901070be48fa60): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow) into ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read [INFO] 2017-12-20T18:29:32.061Z: (6c901070be48f65e): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map into CreateSideInput2/Read(CreateSource) [INFO] 2017-12-20T18:29:32.071Z: (6c901070be48f25c): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) [INFO] 2017-12-20T18:29:32.084Z: (6c901070be48fe5a): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify into ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial [INFO] 2017-12-20T18:29:32.100Z: (6c901070be48fa58): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial into ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map [INFO] 2017-12-20T18:29:32.153Z: (6c901070be48f656): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write into ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify [INFO] 2017-12-20T18:29:32.333Z: (6c901070be48f254): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues into ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read [INFO] 2017-12-20T18:29:32.344Z: (6c901070be48fe52): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) into ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map [INFO] 2017-12-20T18:29:32.355Z: (6c901070be48fa50): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) into ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map [INFO] 2017-12-20T18:29:32.366Z: (6c901070be48f64e): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract into ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues [INFO] 2017-12-20T18:29:32.377Z: (6c901070be48f24c): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write into ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify [INFO] 2017-12-20T18:29:32.388Z: (6c901070be48fe4a): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify into ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial [INFO] 2017-12-20T18:29:32.400Z: (6c901070be48fa48): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map into CreateSideInput1/Read(CreateSource) [INFO] 2017-12-20T18:29:32.411Z: (6c901070be48f646): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues into ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read [INFO] 2017-12-20T18:29:32.422Z: (6c901070be48f244): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) [INFO] 2017-12-20T18:29:32.432Z: (6c901070be48fe42): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial into ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map [INFO] 2017-12-20T18:29:32.444Z: (6c901070be48fa40): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map into ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract [INFO] 2017-12-20T18:29:32.457Z: (6c901070be48f63e): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow) into ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read [INFO] 2017-12-20T18:29:32.657Z: (98794f4d69e921fc): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-12-20T18:29:32.678Z: (c65dd9d0cecd8846): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-12-20T18:29:32.701Z: (ad5f77405ff54198): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-12-20T18:29:32.710Z: (6275739d5527939b): Starting 1 workers in us-central1-f... [INFO] 2017-12-20T18:29:32.812Z: (ad5f77405ff5412a): Executing operation CreateSideInputUnread/Read(CreateSource)+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write [INFO] 2017-12-20T18:29:32.834Z: (c65dd9d0cecd8025): Executing operation CreateSideInput2/Read(CreateSource)+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write [INFO] 2017-12-20T18:29:32.858Z: (b77fc1e66eda2902): Executing operation CreateSideInput1/Read(CreateSource)+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write [INFO] 2017-12-20T18:29:37.346Z: (e8904889a58964f6): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:29:37.374Z: (e8904889a58967ac): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-20T18:29:39.406Z: (2882e95d210ffd85): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] 2017-12-20T18:29:40.898Z: (47688d546ea200bc): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] 2017-12-20T18:29:42.972Z: (1ed0532199b93d34): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] Job 2017-12-20_10_26_40-10322894196239749927 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_26_40-10322894196239749927. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-12-20T18:29:46.430Z: (5add4ec47c2d08b2): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2017-12-20T18:29:51.538Z: (f23489a8cae30a3a): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2017-12-20T18:29:55.180Z: (2882e95d210ff93c): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2017-12-20T18:29:55.793Z: (7588cadfddc07c71): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:29:55.807Z: (7588cadfddc07b0b): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-20T18:29:56.623Z: (47688d546ea20033): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2017-12-20T18:29:58.854Z: (1ed0532199b93435): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2017-12-20T18:29:58.494Z: (a1ad2f95bd5cbf61): Autoscaling: Resized worker pool from 3 to 0. [INFO] 2017-12-20T18:29:58.516Z: (a1ad2f95bd5cb94f): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-20T18:29:58.555Z: (d82854352d27ad91): Worker pool stopped. [INFO] 2017-12-20T18:30:02.772Z: (aa191df2060ddd11): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:30:02.782Z: (aa191df2060dd19f): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-12-20_10_26_32-3909826653978541338 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_26_32-3909826653978541338. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-12-20_10_26_51-4295054217336946933 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_26_51-4295054217336946933. Found 3 success, 0 failures out of 3 expected assertions. [INFO] Job 2017-12-20_10_27_25-6867452748621078760 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_27_25-6867452748621078760. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-12-20T18:30:14.247Z: (c0b2f021315e3cc7): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:30:14.266Z: (c0b2f021315e3c69): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-20T18:30:14.573Z: (534967511353ca17): Workers have started successfully. [INFO] 2017-12-20T18:30:16.158Z: (19f1f2c164b950dd): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:30:16.169Z: (19f1f2c164b9567b): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-20T18:30:16.191Z: (41df78a5a42e994d): Worker pool stopped. [INFO] 2017-12-20T18:30:14.761Z: (10a4ba27ca0b289f): Workers have started successfully. [INFO] 2017-12-20T18:30:19.982Z: (1d04435f1d796810): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:30:19.999Z: (1d04435f1d796392): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-12-20_10_27_40-3043146084031043828 finished with status DONE. [INFO] 2017-12-20T18:30:21.665Z: (8fb93563f16d0c9b): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:30:21.686Z: (8fb93563f16d0041): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Success result for Dataflow job 2017-12-20_10_27_40-3043146084031043828. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-12-20_10_27_22-11256329588819308137 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_27_22-11256329588819308137. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-12-20_10_27_20-2388575474333855808 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_27_20-2388575474333855808. Found 2 success, 0 failures out of 2 expected assertions. [INFO] Job 2017-12-20_10_26_56-54914174094488482 failed with status FAILED. [INFO] Success result for Dataflow job 2017-12-20_10_26_56-54914174094488482. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-12-20T18:30:30.857Z: (c3418a892c4e4ec1): Workers have started successfully. [INFO] 2017-12-20T18:30:31.715Z: (879f373764cae1dd): Executing operation PAssert$364/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-12-20T18:30:31.765Z: (e69044b1a656199f): Executing operation PAssert$364/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-12-20T18:30:31.885Z: (e69044b1a65618d3): 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] 2017-12-20T18:30:31.908Z: (879f373764caee35): 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] 2017-12-20T18:30:32.518Z: (833a7e8c80db08f8): Workers have started successfully. [INFO] 2017-12-20T18:30:30.822Z: (af8c78298ce14ac4): Workers have started successfully. [INFO] 2017-12-20T18:30:35.590Z: (bff777879fea4445): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-12-20T18:30:35.665Z: (bff777879fea458d): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-12-20T18:30:35.823Z: (a1c273458820af84): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-12-20T18:30:38.405Z: (879f373764cae1fb): Executing operation PAssert$364/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-12-20T18:30:38.469Z: (e69044b1a6561ebf): 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] 2017-12-20T18:30:40.413Z: (bff777879fea4f79): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-12-20T18:30:40.481Z: (73f503904aebffb8): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-12-20T18:30:40.630Z: (73f503904aebf6df): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-12-20T18:30:45.406Z: (75a8e395204443bb): Cleaning up. [INFO] 2017-12-20T18:30:45.463Z: (75a8e39520444f59): Stopping worker pool... [INFO] 2017-12-20T18:30:44.680Z: (2a6f7ad10830bed6): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-12-20T18:30:44.773Z: (2a6f7ad10830b88e): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-12-20T18:30:44.971Z: (bff777879fea457a): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-12-20T18:30:46.481Z: (98794f4d69e92608): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-12-20T18:30:46.526Z: (98794f4d69e92e10): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-12-20T18:30:46.660Z: (98794f4d69e92f1b): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-12-20T18:30:48.619Z: (b77fc1e66eda2756): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-12-20T18:30:48.688Z: (b77fc1e66eda29de): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-12-20T18:30:48.829Z: (b77fc1e66eda25aa): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-12-20T18:30:49.842Z: (4c49697f02cd7d87): Executing operation PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-12-20T18:30:49.895Z: (4c49697f02cd776f): Executing operation PAssert$367/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-12-20T18:30:50.049Z: (a26c54014b7b805e): 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] 2017-12-20T18:30:50.076Z: (4c49697f02cd710e): 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] 2017-12-20T18:30:56.524Z: (bff777879fea4a33): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-12-20T18:30:56.593Z: (2a6f7ad10830be59): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInputUnread/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-12-20T18:30:58.353Z: (5a7b678157ee9dcb): Executing operation PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-12-20T18:30:58.415Z: (5a7b678157ee9143): Executing operation PAssert$366/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-12-20T18:30:58.571Z: (4205157881954fe5): 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] 2017-12-20T18:30:58.605Z: (5a7b678157ee91ef): 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] 2017-12-20T18:30:58.768Z: (73f503904aebff04): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-12-20T18:30:58.821Z: (bff777879fea4b7b): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInput1/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-12-20T18:31:00.605Z: (c65dd9d0cecd8793): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-12-20T18:31:00.660Z: (b77fc1e66eda250b): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInput2/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-12-20T18:31:01.747Z: (ad5f77405ff540a6): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-12-20T18:31:00.106Z: (4c49697f02cd7a1b): Executing operation PAssert$367/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-12-20T18:31:00.169Z: (4c49697f02cd7ec6): 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] 2017-12-20T18:31:00.993Z: (a1c273458820aafd): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-12-20T18:31:01.049Z: (73f503904aebfad7): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInput2/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-12-20T18:31:01.812Z: (ad5f77405ff5404e): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-12-20T18:31:01.943Z: (c65dd9d0cecd855e): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-12-20T18:31:06.050Z: (4205157881954611): Executing operation PAssert$366/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-12-20T18:31:06.117Z: (5a7b678157ee9f4e): 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] 2017-12-20T18:31:07.636Z: (1f032a4f8678ef70): Cleaning up. [INFO] 2017-12-20T18:31:07.718Z: (1f032a4f8678ef6a): Stopping worker pool... [INFO] 2017-12-20T18:31:12.363Z: (b77fc1e66eda2efa): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/CreateDataflowView [INFO] 2017-12-20T18:31:12.321Z: (e90ebb2bd8a9be80): Cleaning up. [INFO] 2017-12-20T18:31:12.406Z: (e90ebb2bd8a9b8f6): Stopping worker pool... [INFO] 2017-12-20T18:31:14.046Z: (c65dd9d0cecd8833): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-12-20T18:31:14.113Z: (c65dd9d0cecd81d6): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInputUnread/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-12-20T18:31:14.023Z: (bff777879fea4aee): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/CreateDataflowView [INFO] 2017-12-20T18:31:15.164Z: (ad5f77405ff546cd): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-12-20T18:31:15.215Z: (98794f4d69e9222c): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInput1/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-12-20T18:31:21.387Z: (a1c273458820aaa7): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/CreateDataflowView [INFO] 2017-12-20T18:31:23.740Z: (2a6f7ad10830b69a): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/CreateDataflowView [INFO] 2017-12-20T18:31:23.979Z: (2a6f7ad10830bdf7): Executing operation PAssert$365/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-12-20T18:31:24.150Z: (a1c273458820a7c7): Executing operation Create.Values/Read(CreateSource)+ParDo(Test)+PAssert$365/GroupGlobally/Window.Into()/Window.Assign+PAssert$365/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$365/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$365/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$365/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$365/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-12-20T18:31:28.201Z: (ad5f77405ff54649): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/CreateDataflowView [INFO] 2017-12-20T18:31:29.559Z: (a1c273458820a1d0): Executing operation PAssert$365/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-12-20T18:31:29.622Z: (a1c273458820a918): Executing operation PAssert$365/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-12-20T18:31:29.783Z: (2a6f7ad10830b732): 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] 2017-12-20T18:31:29.822Z: (a1c273458820a71b): 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] 2017-12-20T18:31:29.737Z: (98794f4d69e92462): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/CreateDataflowView [INFO] 2017-12-20T18:31:29.963Z: (c65dd9d0cecd8fd0): Executing operation PAssert$363/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-12-20T18:31:30.101Z: (c65dd9d0cecd8902): Executing operation Create.Values/Read(CreateSource)+ParDo(Test)+PAssert$363/GroupGlobally/Window.Into()/Window.Assign+PAssert$363/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$363/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$363/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$363/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$363/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-12-20T18:31:36.480Z: (c65dd9d0cecd83b6): Executing operation PAssert$363/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-12-20T18:31:36.544Z: (98794f4d69e92678): Executing operation PAssert$363/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-12-20T18:31:36.703Z: (c65dd9d0cecd87de): Executing operation PAssert$363/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$363/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$363/GroupGlobally/GroupDummyAndContents/Reify+PAssert$363/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-12-20T18:31:36.726Z: (98794f4d69e9228c): Executing operation PAssert$363/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$363/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$363/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$363/GroupGlobally/RewindowActuals/Window.Assign+PAssert$363/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$363/GroupGlobally/GroupDummyAndContents/Reify+PAssert$363/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-12-20T18:31:38.525Z: (2a6f7ad10830bdc6): Executing operation PAssert$365/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-12-20T18:31:38.585Z: (2a6f7ad10830b847): 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] 2017-12-20T18:31:43.460Z: (189044878aeae299): Cleaning up. [INFO] 2017-12-20T18:31:43.552Z: (189044878aeae593): Stopping worker pool... [INFO] 2017-12-20T18:31:45.042Z: (98794f4d69e9259d): Executing operation PAssert$363/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-12-20T18:31:45.121Z: (98794f4d69e92aa4): Executing operation PAssert$363/GroupGlobally/GroupDummyAndContents/Read+PAssert$363/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$363/GroupGlobally/Values/Values/Map+PAssert$363/GroupGlobally/ParDo(Concat)+PAssert$363/GetPane/Map+PAssert$363/RunChecks+PAssert$363/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-12-20T18:31:49.041Z: (6c901070be48f42d): Cleaning up. [INFO] 2017-12-20T18:31:49.153Z: (6c901070be48f827): Stopping worker pool... [INFO] 2017-12-20T18:32:06.042Z: (5add4ec47c2d0f91): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:32:06.082Z: (5add4ec47c2d004b): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-12-20_10_29_21-3934343330318550079 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_29_21-3934343330318550079. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-12-20T18:32:18.594Z: (47688d546ea20c0a): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:32:18.640Z: (47688d546ea20b4c): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-12-20_10_29_26-4286999442610982459 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_29_26-4286999442610982459. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-12-20T18:32:28.034Z: (1ed0532199b939d6): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:32:28.053Z: (1ed0532199b93b24): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-20T18:32:28.093Z: (e90ebb2bd8a9bc3e): Worker pool stopped. [INFO] Job 2017-12-20_10_29_24-2467598611122860272 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_29_24-2467598611122860272. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-12-20T18:32:58.408Z: (f23489a8cae30aeb): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:32:58.439Z: (f23489a8cae308b9): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-20T18:33:04.888Z: (2882e95d210ffb83): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-20T18:33:04.923Z: (2882e95d210ff645): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-12-20_10_29_15-8013267324021204611 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_29_15-8013267324021204611. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-12-20_10_29_22-7757248189798433941 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-20_10_29_22-7757248189798433941. Found 1 success, 0 failures out of 1 expected assertions. 2017-12-20T18:33:14.958 [INFO] Running org.apache.beam.sdk.transforms.ParDoTest 2017-12-20T18:33:15.396 [INFO] Tests run: 44, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 800.555 s - in org.apache.beam.sdk.transforms.ParDoTest 2017-12-20T18:33:15.397 [INFO] Running org.apache.beam.sdk.values.PDoneTest 2017-12-20T18:33:15.410 [WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 s - in org.apache.beam.sdk.values.PDoneTest 2017-12-20T18:33:15.417 [INFO] Running org.apache.beam.sdk.transforms.KvSwapTest 2017-12-20T18:33:15.430 [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 204.511 s - in org.apache.beam.sdk.transforms.KvSwapTest 2017-12-20T18:33:15.430 [INFO] Running org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest 2017-12-20T18:33:15.438 [INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 33.559 s - in org.apache.beam.sdk.io.TextIOReadTest$BasicIOTest 2017-12-20T18:33:15.442 [INFO] 2017-12-20T18:33:15.443 [INFO] Results: 2017-12-20T18:33:15.443 [INFO] 2017-12-20T18:33:15.443 [WARNING] Tests run: 261, Failures: 0, Errors: 0, Skipped: 1 2017-12-20T18:33:15.443 [INFO] [JENKINS] Recording test results 2017-12-20T18:33:16.465 [INFO] 2017-12-20T18:33:16.466 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-12-20T18:33:16.725 [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 [JENKINS] Archiving disabled 2017-12-20T18:33:31.000 [INFO] ------------------------------------------------------------------------ 2017-12-20T18:33:31.000 [INFO] Reactor Summary: 2017-12-20T18:33:31.000 [INFO] 2017-12-20T18:33:31.000 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 6.271 s] 2017-12-20T18:33:31.000 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 6.948 s] 2017-12-20T18:33:31.000 [INFO] Apache Beam :: Model ............................... SUCCESS [ 1.589 s] 2017-12-20T18:33:31.000 [INFO] Apache Beam :: Model :: Pipeline ................... SUCCESS [ 9.099 s] 2017-12-20T18:33:31.000 [INFO] Apache Beam :: Model :: Job Management ............. SUCCESS [ 8.042 s] 2017-12-20T18:33:31.000 [INFO] Apache Beam :: Model :: Fn Execution ............... SUCCESS [ 9.260 s] 2017-12-20T18:33:31.000 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.502 s] 2017-12-20T18:33:31.000 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 2.362 s] 2017-12-20T18:33:31.000 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [02:01 min] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 2.394 s] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: Runners :: Local Java Core .......... SUCCESS [ 6.142 s] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [ 14.883 s] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [ 24.577 s] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [09:52 min] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 2.844 s] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 2.397 s] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [04:39 min] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 20.683 s] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [01:37 min] 2017-12-20T18:33:31.001 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:27 h] 2017-12-20T18:33:31.001 [INFO] ------------------------------------------------------------------------ 2017-12-20T18:33:31.001 [INFO] BUILD SUCCESS 2017-12-20T18:33:31.001 [INFO] ------------------------------------------------------------------------ 2017-12-20T18:33:31.001 [INFO] Total time: 01:48 h 2017-12-20T18:33:31.001 [INFO] Finished at: 2017-12-20T18:33:31+00:00 2017-12-20T18:33:33.240 [INFO] Final Memory: 494M/2631M 2017-12-20T18:33:33.240 [INFO] ------------------------------------------------------------------------ channel stopped Not sending mail to unregistered user [email protected]
