See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4213/display/redirect>
------------------------------------------ [...truncated 21.15 MB...] [INFO] 2017-10-23T07:39:19.628Z: (b6ee9ab08b71231): Checking required Cloud APIs are enabled. [INFO] 2017-10-23T07:39:23.390Z: (b6ee9ab08b71581): Expanding CoGroupByKey operations into optimizable parts. [INFO] 2017-10-23T07:39:23.407Z: (b6ee9ab08b71aea): Expanding GroupByKey operations into optimizable parts. [INFO] 2017-10-23T07:39:23.411Z: (b6ee9ab08b71a84): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns [INFO] 2017-10-23T07:39:23.442Z: (b6ee9ab08b71754): Fusing adjacent ParDo, Read, Write, and Flatten operations [INFO] 2017-10-23T07:39:23.444Z: (b6ee9ab08b716ee): Elided trivial flatten [INFO] 2017-10-23T07:39:23.446Z: (b6ee9ab08b71688): Elided trivial flatten [INFO] 2017-10-23T07:39:23.448Z: (b6ee9ab08b71622): Elided trivial flatten [INFO] 2017-10-23T07:39:23.453Z: (b6ee9ab08b715bc): Unzipping flatten s42 for input s37.37 [INFO] 2017-10-23T07:39:23.455Z: (b6ee9ab08b71556): Fusing unzipped copy of PAssert$335/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$335/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-10-23T07:39:23.457Z: (b6ee9ab08b714f0): Fusing consumer PAssert$335/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$335/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-10-23T07:39:23.459Z: (b6ee9ab08b7148a): Unzipping flatten s42-u97 for input s44-reify-value79-c95 [INFO] 2017-10-23T07:39:23.462Z: (b6ee9ab08b71424): Fusing unzipped copy of PAssert$335/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$335/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-23T07:39:23.464Z: (b6ee9ab08b713be): Fusing consumer PAssert$335/GroupGlobally/ParDo(Concat) into PAssert$335/GroupGlobally/Values/Values/Map [INFO] 2017-10-23T07:39:23.466Z: (b6ee9ab08b71358): Fusing consumer PAssert$335/RunChecks into PAssert$335/GetPane/Map [INFO] 2017-10-23T07:39:23.468Z: (b6ee9ab08b712f2): Fusing consumer PAssert$335/VerifyAssertions/ParDo(DefaultConclude) into PAssert$335/RunChecks [INFO] 2017-10-23T07:39:23.470Z: (b6ee9ab08b7128c): Fusing consumer PAssert$335/GetPane/Map into PAssert$335/GroupGlobally/ParDo(Concat) [INFO] 2017-10-23T07:39:23.472Z: (b6ee9ab08b71226): Fusing consumer PAssert$335/GroupGlobally/Values/Values/Map into PAssert$335/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-10-23T07:39:23.474Z: (b6ee9ab08b711c0): Fusing consumer ParDo(Test) into Create.Values/Read(CreateSource) [INFO] 2017-10-23T07:39:23.477Z: (b6ee9ab08b7115a): Fusing consumer PAssert$335/GroupGlobally/Window.Into()/Window.Assign into ParDo(Test) [INFO] 2017-10-23T07:39:23.479Z: (b6ee9ab08b710f4): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-10-23T07:39:23.481Z: (b6ee9ab08b7108e): Fusing consumer PAssert$335/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$335/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-10-23T07:39:23.484Z: (b6ee9ab08b71028): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-10-23T07:39:23.485Z: (b6ee9ab08b71fc2): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-10-23T07:39:23.487Z: (b6ee9ab08b71f5c): Fusing consumer PAssert$335/GroupGlobally/RewindowActuals/Window.Assign into PAssert$335/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-10-23T07:39:23.489Z: (b6ee9ab08b71ef6): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$335/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-10-23T07:39:23.491Z: (b6ee9ab08b71e90): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$335/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-10-23T07:39:23.493Z: (b6ee9ab08b71e2a): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$335/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-10-23T07:39:23.495Z: (b6ee9ab08b71dc4): Fusing consumer PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$335/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-10-23T07:39:23.498Z: (b6ee9ab08b71d5e): Fusing consumer PAssert$335/GroupGlobally/GroupDummyAndContents/Reify into PAssert$335/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-10-23T07:39:23.500Z: (b6ee9ab08b71cf8): Fusing consumer PAssert$335/GroupGlobally/GroupDummyAndContents/Write into PAssert$335/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-23T07:39:23.502Z: (b6ee9ab08b71c92): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) [INFO] 2017-10-23T07:39:23.504Z: (b6ee9ab08b71c2c): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) into ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map [INFO] 2017-10-23T07:39:23.506Z: (b6ee9ab08b71bc6): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract into ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues [INFO] 2017-10-23T07:39:23.509Z: (b6ee9ab08b71b60): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map into ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract [INFO] 2017-10-23T07:39:23.511Z: (b6ee9ab08b71afa): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map into CreateSideInputUnread/Read(CreateSource) [INFO] 2017-10-23T07:39:23.513Z: (b6ee9ab08b71a94): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify into ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial [INFO] 2017-10-23T07:39:23.515Z: (b6ee9ab08b71a2e): Fusing consumer PAssert$335/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$335/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-10-23T07:39:23.517Z: (b6ee9ab08b719c8): 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-10-23T07:39:23.519Z: (b6ee9ab08b71962): 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-10-23T07:39:23.522Z: (b6ee9ab08b718fc): 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-10-23T07:39:23.524Z: (b6ee9ab08b71896): Fusing consumer ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) into ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read [INFO] 2017-10-23T07:39:23.526Z: (b6ee9ab08b71830): 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-10-23T07:39:23.528Z: (b6ee9ab08b717ca): 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-10-23T07:39:23.531Z: (b6ee9ab08b71764): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) into ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read [INFO] 2017-10-23T07:39:23.533Z: (b6ee9ab08b716fe): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map into CreateSideInput2/Read(CreateSource) [INFO] 2017-10-23T07:39:23.535Z: (b6ee9ab08b71698): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) [INFO] 2017-10-23T07:39:23.537Z: (b6ee9ab08b71632): 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-10-23T07:39:23.539Z: (b6ee9ab08b715cc): 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-10-23T07:39:23.541Z: (b6ee9ab08b71566): 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-10-23T07:39:23.544Z: (b6ee9ab08b71500): 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-10-23T07:39:23.546Z: (b6ee9ab08b7149a): Fusing consumer ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) into ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map [INFO] 2017-10-23T07:39:23.548Z: (b6ee9ab08b71434): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) into ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map [INFO] 2017-10-23T07:39:23.550Z: (b6ee9ab08b713ce): 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-10-23T07:39:23.552Z: (b6ee9ab08b71368): 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-10-23T07:39:23.554Z: (b6ee9ab08b71302): 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-10-23T07:39:23.556Z: (b6ee9ab08b7129c): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map into CreateSideInput1/Read(CreateSource) [INFO] 2017-10-23T07:39:23.558Z: (b6ee9ab08b71236): 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-10-23T07:39:23.560Z: (b6ee9ab08b711d0): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) [INFO] 2017-10-23T07:39:23.563Z: (b6ee9ab08b7116a): 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-10-23T07:39:23.565Z: (b6ee9ab08b71104): 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-10-23T07:39:23.567Z: (b6ee9ab08b7109e): Fusing consumer ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) into ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read [INFO] 2017-10-23T07:39:23.577Z: (b6ee9ab08b71fd2): Adding StepResource setup and teardown to workflow graph. [INFO] 2017-10-23T07:39:23.668Z: (dba6cacda41b35d3): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-10-23T07:39:23.676Z: (a93faf2aaac1cb26): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-10-23T07:39:23.684Z: (5704f04390abfa98): Starting 1 workers in us-central1-f... [INFO] 2017-10-23T07:39:23.685Z: (b34b039a8b221317): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-10-23T07:39:23.724Z: (b34b039a8b2211b1): 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-10-23T07:39:23.743Z: (dba6cacda41b3a98): 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-10-23T07:39:23.755Z: (a93faf2aaac1c16a): 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] Job 2017-10-23_00_36_26-11867234585665718875 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-23_00_36_26-11867234585665718875. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-10-23T07:39:30.919Z: (cf26e21b74eca5d0): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] 2017-10-23T07:39:30.082Z: (86258cd475f09db2): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] 2017-10-23T07:39:32.195Z: (a250c3fd75f8b7a5): Executing operation ParDo(Anonymous)/BatchStatefulParDoOverrides.GbkBeforeStatefulParDo/PartitionKeys/Close [INFO] 2017-10-23T07:39:32.210Z: (a250c3fd75f8b08d): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-23T07:39:32.251Z: (a250c3fd75f8bed1): Executing operation ParDo(Anonymous)/BatchStatefulParDoOverrides.GbkBeforeStatefulParDo/PartitionKeys/Read+ParDo(Anonymous)/ParDo(BatchStateful)+PAssert$332/GroupGlobally/Window.Into()/Window.Assign+PAssert$332/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$332/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$332/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-23T07:39:39.004Z: (615814d8561b51c): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-23T07:39:39.006Z: (615814d8561ba46): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-23T07:39:40.244Z: (df81d81bbc2bab9b): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-23T07:39:40.246Z: (df81d81bbc2baa99): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-23T07:39:41.440Z: (cf26e21b74eca8a9): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2017-10-23T07:39:40.623Z: (86258cd475f09b39): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2017-10-23T07:39:41.415Z: (7507f96bac2805ef): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-23T07:39:41.417Z: (7507f96bac280455): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-23T07:39:41.652Z: (a250c3fd75f8b6db): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-23T07:39:41.666Z: (a250c3fd75f8bfc3): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-23T07:39:41.708Z: (a250c3fd75f8be07): Executing operation PAssert$332/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$332/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$332/GroupGlobally/GroupDummyAndContents/Reify+PAssert$332/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-23T07:39:41.718Z: (82e55126c6a7575a): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$332/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$332/GroupGlobally/RewindowActuals/Window.Assign+PAssert$332/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$332/GroupGlobally/GroupDummyAndContents/Reify+PAssert$332/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-23T07:39:45.228Z: (c21246ead63ce12d): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-23T07:39:45.230Z: (c21246ead63ce08f): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-10-23_00_36_33-16509774531188948797 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-23_00_36_33-16509774531188948797. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-10-23_00_36_35-3484174561289793594 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-23_00_36_35-3484174561289793594. Found 2 success, 0 failures out of 2 expected assertions. [INFO] Job 2017-10-23_00_36_40-13802795828699285903 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-23_00_36_40-13802795828699285903. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-10-23T07:39:48.624Z: (6f5e0114bfd60702): Workers have started successfully. [INFO] Job 2017-10-23_00_36_33-3585510529454354809 failed with status FAILED. [INFO] Success result for Dataflow job 2017-10-23_00_36_33-3585510529454354809. Found 0 success, 0 failures out of 0 expected assertions. [INFO] 2017-10-23T07:39:53.488Z: (a250c3fd75f8b4ba): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-23T07:39:53.508Z: (82e55126c6a75894): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Read+PAssert$332/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$332/GroupGlobally/Values/Values/Map+PAssert$332/GroupGlobally/ParDo(Concat)+PAssert$332/GetPane/Map+PAssert$332/RunChecks+PAssert$332/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-23T07:39:57.418Z: (60d767d42d236646): Cleaning up. [INFO] 2017-10-23T07:39:57.422Z: (60d767d42d2361f2): Stopping worker pool... [INFO] 2017-10-23T07:40:03.907Z: (404fa6a8a7b1ba49): Workers have started successfully. [INFO] 2017-10-23T07:40:09.602Z: (2a0bba3c261c9a38): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-23T07:40:09.636Z: (128dc12273773fb): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-23T07:40:09.704Z: (128dc1227377afe): 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/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-10-23T07:40:11.825Z: (ef10581ff50a643f): Workers have started successfully. [INFO] 2017-10-23T07:40:15.278Z: (2a0bba3c261c9bcd): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-23T07:40:15.306Z: (51bbdff81460d558): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-23T07:40:15.378Z: (51bbdff81460d8cf): 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/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-10-23T07:40:23.677Z: (2755633f89559a5c): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-23T07:40:23.704Z: (2a0bba3c261c90ab): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-23T07:40:23.780Z: (2a0bba3c261c9c88): 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/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-10-23T07:40:28.186Z: (2a0bba3c261c9166): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-23T07:40:28.215Z: (2a0bba3c261c9a67): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-10-23T07:40:31.060Z: (d80d3eca3ad46b74): Executing operation PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-23T07:40:31.093Z: (d80d3eca3ad46d2c): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-23T07:40:30.276Z: (fa99e0a503d357b6): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-23T07:40:30.312Z: (dba6cacda41b3eb3): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-23T07:40:30.389Z: (fa99e0a503d35abe): 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/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-10-23T07:40:29.311Z: (51bbdff81460d8a9): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-23T07:40:29.341Z: (2755633f89559c4b): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-10-23T07:40:31.167Z: (d80d3eca3ad46b89): Executing operation PAssert$334/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$334/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$334/GroupGlobally/GroupDummyAndContents/Reify+PAssert$334/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-23T07:40:31.197Z: (35b116c45cdc36e9): Executing operation PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$334/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$334/GroupGlobally/RewindowActuals/Window.Assign+PAssert$334/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$334/GroupGlobally/GroupDummyAndContents/Reify+PAssert$334/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-23T07:40:32.550Z: (a93faf2aaac1c8e5): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-23T07:40:32.579Z: (dba6cacda41b3378): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-23T07:40:32.661Z: (dba6cacda41b3205): 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/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-10-23T07:40:36.886Z: (d80d3eca3ad46254): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-23T07:40:36.909Z: (35b116c45cdc3117): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Read+PAssert$334/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$334/GroupGlobally/Values/Values/Map+PAssert$334/GroupGlobally/ParDo(Concat)+PAssert$334/GetPane/Map+PAssert$334/RunChecks+PAssert$334/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-23T07:40:35.873Z: (a93faf2aaac1cefc): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-23T07:40:35.909Z: (b34b039a8b221e46): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-23T07:40:35.992Z: (a93faf2aaac1cc34): 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/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write [INFO] 2017-10-23T07:40:37.017Z: (2755633f89559228): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-23T07:40:40.699Z: (51bbdff81460d2fb): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-23T07:40:42.377Z: (2a0bba3c261c9a96): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-23T07:40:42.401Z: (2a0bba3c261c9397): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-10-23T07:40:44.127Z: (1ada5ec8a2af9bc0): Cleaning up. [INFO] 2017-10-23T07:40:44.131Z: (1ada5ec8a2af9634): Stopping worker pool... [INFO] 2017-10-23T07:40:45.420Z: (dba6cacda41b3403): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-23T07:40:45.440Z: (dba6cacda41b3774): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-10-23T07:40:46.093Z: (128dc12273770ed): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-23T07:40:46.150Z: (128dc1227377f21): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-23T07:40:46.192Z: (128dc122737756c): Executing operation Create.Values/Read(CreateSource)+ParDo(Test)+PAssert$333/GroupGlobally/Window.Into()/Window.Assign+PAssert$333/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$333/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$333/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-23T07:40:49.435Z: (128dc122737725e): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-23T07:40:49.476Z: (128dc12273771a6): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-23T07:40:49.678Z: (128dc1227377fda): Executing operation PAssert$333/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$333/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$333/GroupGlobally/GroupDummyAndContents/Reify+PAssert$333/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-23T07:40:49.711Z: (2a0bba3c261c999d): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$333/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$333/GroupGlobally/RewindowActuals/Window.Assign+PAssert$333/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$333/GroupGlobally/GroupDummyAndContents/Reify+PAssert$333/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-23T07:40:49.763Z: (3a6f5ad7a6345002): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-23T07:40:49.765Z: (3a6f5ad7a6345ce0): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-23T07:40:52.430Z: (2a0bba3c261c9e7b): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-23T07:40:52.464Z: (2a0bba3c261c977c): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Read+PAssert$333/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$333/GroupGlobally/Values/Values/Map+PAssert$333/GroupGlobally/ParDo(Concat)+PAssert$333/GetPane/Map+PAssert$333/RunChecks+PAssert$333/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-23T07:40:55.248Z: (fa99e0a503d35990): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-23T07:40:55.266Z: (fa99e0a503d35837): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] Job 2017-10-23_00_38_10-11468166265022665312 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-23_00_38_10-11468166265022665312. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-10-23T07:40:56.361Z: (7b8e9115ec870762): Cleaning up. [INFO] 2017-10-23T07:40:56.372Z: (7b8e9115ec8708ee): Stopping worker pool... [INFO] 2017-10-23T07:40:58.887Z: (fa99e0a503d35021): Executing operation ViewSideInput2/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-23T07:40:59.464Z: (a93faf2aaac1cdf2): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-23T07:40:59.481Z: (a93faf2aaac1cf83): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) [INFO] 2017-10-23T07:41:04.271Z: (a93faf2aaac1c8e9): Executing operation ViewSideInputUnread/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-23T07:41:05.610Z: (dba6cacda41b3f6c): Executing operation ViewSideInput1/Combine.GloballyAsSingletonView/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-23T07:41:05.671Z: (dba6cacda41b39bf): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-23T07:41:05.716Z: (dba6cacda41b3e84): Executing operation Create.Values/Read(CreateSource)+ParDo(Test)+PAssert$335/GroupGlobally/Window.Into()/Window.Assign+PAssert$335/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$335/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$335/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-23T07:41:10.189Z: (dba6cacda41b3cf2): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-23T07:41:10.204Z: (dba6cacda41b332a): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-23T07:41:10.248Z: (dba6cacda41b3ab6): Executing operation PAssert$335/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$335/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$335/GroupGlobally/GroupDummyAndContents/Reify+PAssert$335/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-23T07:41:10.261Z: (a93faf2aaac1cc38): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$335/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$335/GroupGlobally/RewindowActuals/Window.Assign+PAssert$335/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$335/GroupGlobally/GroupDummyAndContents/Reify+PAssert$335/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-23T07:41:13.840Z: (dba6cacda41b3ed1): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-23T07:41:13.862Z: (dba6cacda41b3242): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Read+PAssert$335/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$335/GroupGlobally/Values/Values/Map+PAssert$335/GroupGlobally/ParDo(Concat)+PAssert$335/GetPane/Map+PAssert$335/RunChecks+PAssert$335/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-23T07:41:15.709Z: (b6ee9ab08b7153b): Cleaning up. [INFO] 2017-10-23T07:41:15.713Z: (b6ee9ab08b7146f): Stopping worker pool... [INFO] 2017-10-23T07:41:42.398Z: (86258cd475f09104): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-23T07:41:42.400Z: (86258cd475f09932): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-10-23T07:41:48.251Z: (3cfed342d414acee): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-23T07:41:48.253Z: (3cfed342d414a4a4): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-10-23_00_39_16-7326965854483825926 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-23_00_39_16-7326965854483825926. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-10-23_00_38_55-5781937169609879893 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-23_00_38_55-5781937169609879893. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-10-23T07:42:10.631Z: (cf26e21b74ecaa4c): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-10-23T07:42:10.633Z: (cf26e21b74eca6de): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-10-23_00_39_17-14534096078332783330 finished with status DONE. [INFO] Success result for Dataflow job 2017-10-23_00_39_17-14534096078332783330. Found 1 success, 0 failures out of 1 expected assertions. 2017-10-23T07:42:18.993 [INFO] Running org.apache.beam.sdk.transforms.ParDoTest 2017-10-23T07:42:19.692 [INFO] Tests run: 43, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 795.756 s - in org.apache.beam.sdk.transforms.ParDoTest 2017-10-23T07:42:19.693 [INFO] Running org.apache.beam.sdk.values.PDoneTest 2017-10-23T07:42:19.698 [WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 s - in org.apache.beam.sdk.values.PDoneTest 2017-10-23T07:42:19.701 [INFO] 2017-10-23T07:42:19.701 [INFO] Results: 2017-10-23T07:42:19.701 [INFO] 2017-10-23T07:42:19.702 [WARNING] Tests run: 259, Failures: 0, Errors: 0, Skipped: 1 2017-10-23T07:42:19.702 [INFO] [JENKINS] Recording test results 2017-10-23T07:42:34.898 [INFO] 2017-10-23T07:42:34.898 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-10-23T07:42:35.228 [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 2017-10-23T07:42:52.243 [INFO] ------------------------------------------------------------------------ 2017-10-23T07:42:52.244 [INFO] Reactor Summary: 2017-10-23T07:42:52.244 [INFO] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 26.690 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 26.382 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Model ............................... SUCCESS [ 1.714 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Model :: Pipeline ................... SUCCESS [ 25.415 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Model :: Job Management ............. SUCCESS [ 9.916 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Model :: Fn Execution ............... SUCCESS [ 12.405 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.499 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 2.639 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [02:56 min] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 2.413 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [01:01 min] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [01:27 min] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [08:58 min] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 2.549 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 3.112 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [ 22.247 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 22.289 s] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [01:40 min] 2017-10-23T07:42:52.244 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:20 h] 2017-10-23T07:42:52.244 [INFO] ------------------------------------------------------------------------ 2017-10-23T07:42:52.244 [INFO] BUILD SUCCESS 2017-10-23T07:42:52.244 [INFO] ------------------------------------------------------------------------ 2017-10-23T07:42:52.244 [INFO] Total time: 01:41 h 2017-10-23T07:42:52.245 [INFO] Finished at: 2017-10-23T07:42:52+00:00 [JENKINS] Archiving disabled 2017-10-23T07:42:55.000 [INFO] Final Memory: 460M/2480M 2017-10-23T07:42:55.000 [INFO] ------------------------------------------------------------------------ channel stopped
