See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4515/display/redirect?page=changes>
Changes: [klk] Add @RequiresStableInput annotation ------------------------------------------ [...truncated 22.68 MB...] [INFO] 2017-12-12T10:30:44.544Z: (7cac5d1041866a0b): Fusing consumer Combine.globally(Count)/ProduceDefault into Combine.globally(Count)/CreateVoid/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds [INFO] 2017-12-12T10:30:44.546Z: (7cac5d1041866c19): Fusing consumer Combine.globally(Count)/CreateVoid/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds into Combine.globally(Count)/CreateVoid/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds [INFO] 2017-12-12T10:30:44.549Z: (7cac5d1041866e27): Fusing consumer Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/ParDo(StreamingPCollectionViewWriter) into Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map [INFO] 2017-12-12T10:30:44.553Z: (7cac5d1041866035): Fusing consumer Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map into Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract [INFO] 2017-12-12T10:30:44.556Z: (7cac5d1041866243): Fusing consumer Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract into Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues [INFO] 2017-12-12T10:30:44.559Z: (7cac5d1041866451): Fusing consumer Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues into Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream [INFO] 2017-12-12T10:30:44.562Z: (7cac5d104186665f): Fusing consumer Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/WriteStream into Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial [INFO] 2017-12-12T10:30:44.564Z: (7cac5d104186686d): Fusing consumer Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial into Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map [INFO] 2017-12-12T10:30:44.567Z: (7cac5d1041866a7b): Fusing consumer Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds into Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds [INFO] 2017-12-12T10:30:44.570Z: (7cac5d1041866c89): Fusing consumer Combine.globally(Count)/Combine.perKey(Count)/Combine.GroupedValues/Extract into Combine.globally(Count)/Combine.perKey(Count)/Combine.GroupedValues [INFO] 2017-12-12T10:30:44.573Z: (7cac5d1041866e97): Fusing consumer s7/GroupByKeyRaw/WriteStream into ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Assign unique key/AddKeys/Map [INFO] 2017-12-12T10:30:44.576Z: (7cac5d10418660a5): Fusing consumer Combine.globally(Count)/Combine.perKey(Count)/Combine.GroupedValues into Combine.globally(Count)/Combine.perKey(Count)/GroupByKey/ReadStream [INFO] 2017-12-12T10:30:44.580Z: (7cac5d10418662b3): Fusing consumer Combine.globally(Count)/Combine.perKey(Count)/GroupByKey/WriteStream into Combine.globally(Count)/Combine.perKey(Count)/GroupByKey+Combine.globally(Count)/Combine.perKey(Count)/Combine.GroupedValues/Partial [INFO] 2017-12-12T10:30:44.582Z: (7cac5d10418664c1): Fusing consumer Combine.globally(Count)/Combine.perKey(Count)/GroupByKey+Combine.globally(Count)/Combine.perKey(Count)/Combine.GroupedValues/Partial into Combine.globally(Count)/WithKeys/AddKeys/Map [INFO] 2017-12-12T10:30:44.585Z: (7cac5d10418666cf): Fusing consumer Combine.globally(Count)/WithKeys/AddKeys/Map into s7/SplittableProcess [INFO] 2017-12-12T10:30:44.587Z: (7cac5d10418668dd): Fusing consumer ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Pair with initial restriction into Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds [INFO] 2017-12-12T10:30:44.590Z: (7cac5d1041866aeb): Fusing consumer ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Explode windows into ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Split restriction [INFO] 2017-12-12T10:30:44.593Z: (7cac5d1041866cf9): Fusing consumer ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Assign unique key/AddKeys/Map into ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Explode windows [INFO] 2017-12-12T10:30:44.912Z: (86941afa7adeda65): Starting 1 workers... [INFO] 2017-12-12T10:30:48.277Z: (693d6189d7e36a): Executing operation Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Pair with initial restriction+ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Split restriction+ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Explode windows+ParDo(SDFWithMultipleOutputsPerBlock)/ParMultiDo(SDFWithMultipleOutputsPerBlock)/Assign unique key/AddKeys/Map+s7/GroupByKeyRaw/WriteStream [INFO] 2017-12-12T10:30:48.281Z: (abc7ffa0f71074d): Executing operation PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(StreamingPCollectionViewWriter) [INFO] 2017-12-12T10:30:48.281Z: (e8bf78b96937d326): Executing operation Combine.globally(Count)/Combine.perKey(Count)/GroupByKey/ReadStream+Combine.globally(Count)/Combine.perKey(Count)/Combine.GroupedValues+Combine.globally(Count)/Combine.perKey(Count)/Combine.GroupedValues/Extract+Combine.globally(Count)/Values/Values/Map+PAssert$365/CreateActual/FilterActuals/Window.Assign+PAssert$365/CreateActual/GatherPanes/Reify.Window/ParDo(Anonymous)+PAssert$365/CreateActual/GatherPanes/WithKeys/AddKeys/Map+PAssert$365/CreateActual/GatherPanes/Window.Into()/Window.Assign+PAssert$365/CreateActual/GatherPanes/GroupByKey/WriteStream+Combine.globally(Count)/View.AsIterable/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/WriteStream [INFO] 2017-12-12T10:30:48.281Z: (74b68314d8bb1d7c): Executing operation Combine.globally(Count)/CreateVoid/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+Combine.globally(Count)/CreateVoid/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+Combine.globally(Count)/ProduceDefault+PAssert$365/CreateActual/FilterActuals/Window.Assign+PAssert$365/CreateActual/GatherPanes/Reify.Window/ParDo(Anonymous)+PAssert$365/CreateActual/GatherPanes/WithKeys/AddKeys/Map+PAssert$365/CreateActual/GatherPanes/Window.Into()/Window.Assign+PAssert$365/CreateActual/GatherPanes/GroupByKey/WriteStream [INFO] 2017-12-12T10:30:48.281Z: (e218408432e3070e): Executing operation PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/ReadStream+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Partial+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/WriteStream [INFO] 2017-12-12T10:30:48.281Z: (3eff6dc5adad6707): Executing operation PAssert$365/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/DataflowRunner.StreamingUnboundedRead.ReadWithIds+PAssert$365/Create.Values/Read(CreateSource)/Read(CreateSource)/Read(BoundedToUnboundedSourceAdapter)/StripIds+PAssert$365/WindowToken/Window.Assign+PAssert$365/RunChecks+PAssert$365/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-12-12T10:30:48.281Z: (abac59aafaa4551e): Executing operation Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/GroupByKey/ReadStream+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)/Combine.GroupedValues/Extract+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map+Combine.globally(Count)/View.AsIterable/View.CreatePCollectionView/ParDo(StreamingPCollectionViewWriter) [INFO] 2017-12-12T10:30:48.285Z: (7cac5d104186673f): Executing operation s7/GroupByKeyRaw/ReadStream+s7/SplittableProcess+Combine.globally(Count)/WithKeys/AddKeys/Map+Combine.globally(Count)/Combine.perKey(Count)/GroupByKey+Combine.globally(Count)/Combine.perKey(Count)/Combine.GroupedValues/Partial+Combine.globally(Count)/Combine.perKey(Count)/GroupByKey/WriteStream [INFO] 2017-12-12T10:30:48.321Z: (d25c108c990e32f0): Executing operation PAssert$365/CreateActual/GatherPanes/GroupByKey/ReadStream+PAssert$365/CreateActual/GatherPanes/GroupByKey/MergeBuckets+PAssert$365/CreateActual/GatherPanes/Values/Values/Map+PAssert$365/CreateActual/ExtractPane/Map+PAssert$365/CreateActual/Flatten.Iterables/FlattenIterables/FlatMap+PAssert$365/CreateActual/RewindowActuals/Window.Assign+PAssert$365/CreateActual/ParDo(Anonymous)+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+PAssert$365/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/WriteStream [INFO] 2017-12-12T10:30:42.496Z: (9011021b9589202c): Autoscaling is enabled for job 2017-12-12_02_30_42-10381080933561868896. The number of workers will be between 1 and 15. [INFO] 2017-12-12T10:30:42.524Z: (9011021b9589279f): Autoscaling was automatically enabled for job 2017-12-12_02_30_42-10381080933561868896. [INFO] 2017-12-12T10:30:45.452Z: (86c6042ed40d30ba): Checking required Cloud APIs are enabled. [INFO] 2017-12-12T10:30:48.856Z: (86c6042ed40d3e4a): Expanding CoGroupByKey operations into optimizable parts. [INFO] 2017-12-12T10:30:48.896Z: (86c6042ed40d30c5): Expanding GroupByKey operations into optimizable parts. [INFO] 2017-12-12T10:30:48.928Z: (86c6042ed40d3b67): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns [INFO] 2017-12-12T10:30:49.010Z: (86c6042ed40d35d5): Fusing adjacent ParDo, Read, Write, and Flatten operations [INFO] 2017-12-12T10:30:49.040Z: (86c6042ed40d3077): Elided trivial flatten [INFO] 2017-12-12T10:30:49.052Z: (86c6042ed40d3b19): Elided trivial flatten [INFO] 2017-12-12T10:30:49.083Z: (86c6042ed40d35bb): Elided trivial flatten [INFO] 2017-12-12T10:30:49.111Z: (86c6042ed40d305d): Elided trivial flatten [INFO] 2017-12-12T10:30:49.142Z: (86c6042ed40d3aff): Elided trivial flatten [INFO] 2017-12-12T10:30:49.168Z: (86c6042ed40d35a1): Elided trivial flatten [INFO] 2017-12-12T10:30:49.195Z: (86c6042ed40d3043): Unzipping flatten s15 for input s10.12 [INFO] 2017-12-12T10:30:49.227Z: (86c6042ed40d3ae5): Fusing unzipped copy of PAssert$366/GroupGlobally/GroupDummyAndContents/Reify, through flatten PAssert$366/GroupGlobally/FlattenDummyAndContents, into producer PAssert$366/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-12-12T10:30:49.262Z: (86c6042ed40d3587): Fusing consumer PAssert$366/VerifyAssertions/ParDo(DefaultConclude) into PAssert$366/RunChecks [INFO] 2017-12-12T10:30:49.293Z: (86c6042ed40d3029): Unzipping flatten s15-u40 for input s17-reify-value0-c38 [INFO] 2017-12-12T10:30:49.324Z: (86c6042ed40d3acb): Fusing unzipped copy of PAssert$366/GroupGlobally/GroupDummyAndContents/Write, through flatten s15-u40, into producer PAssert$366/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-12-12T10:30:49.351Z: (86c6042ed40d356d): Fusing consumer PAssert$366/GetPane/Map into PAssert$366/GroupGlobally/ParDo(Concat) [INFO] 2017-12-12T10:30:49.380Z: (86c6042ed40d300f): Fusing consumer PAssert$366/RunChecks into PAssert$366/GetPane/Map [INFO] 2017-12-12T10:30:49.412Z: (86c6042ed40d3ab1): Fusing consumer PAssert$367/RunChecks into PAssert$367/GetPane/Map [INFO] 2017-12-12T10:30:49.439Z: (86c6042ed40d3553): Fusing consumer PAssert$367/VerifyAssertions/ParDo(DefaultConclude) into PAssert$367/RunChecks [INFO] 2017-12-12T10:30:49.467Z: (86c6042ed40d3ff5): Fusing consumer PAssert$367/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$367/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-12-12T10:30:49.498Z: (86c6042ed40d3a97): Fusing consumer PAssert$367/GroupGlobally/ParDo(Concat) into PAssert$367/GroupGlobally/Values/Values/Map [INFO] 2017-12-12T10:30:49.518Z: (86c6042ed40d3539): Fusing consumer PAssert$367/GetPane/Map into PAssert$367/GroupGlobally/ParDo(Concat) [INFO] 2017-12-12T10:30:49.549Z: (86c6042ed40d3fdb): Fusing consumer PAssert$367/GroupGlobally/Values/Values/Map into PAssert$367/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-12-12T10:30:49.580Z: (86c6042ed40d3a7d): Fusing consumer PAssert$366/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$366/GroupGlobally/GroupDummyAndContents/Read [INFO] 2017-12-12T10:30:49.599Z: (86c6042ed40d351f): Fusing consumer PAssert$366/GroupGlobally/Values/Values/Map into PAssert$366/GroupGlobally/GroupDummyAndContents/GroupByWindow [INFO] 2017-12-12T10:30:49.630Z: (86c6042ed40d3fc1): Fusing consumer PAssert$366/GroupGlobally/ParDo(Concat) into PAssert$366/GroupGlobally/Values/Values/Map [INFO] 2017-12-12T10:30:49.675Z: (86c6042ed40d3a63): Fusing consumer PAssert$367/GroupGlobally/GroupDummyAndContents/Write into PAssert$367/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-12-12T10:30:49.709Z: (86c6042ed40d3505): Unzipping flatten s35 for input s30.32 [INFO] 2017-12-12T10:30:49.740Z: (86c6042ed40d3fa7): Fusing unzipped copy of PAssert$367/GroupGlobally/GroupDummyAndContents/Reify, through flatten PAssert$367/GroupGlobally/FlattenDummyAndContents, into producer PAssert$367/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-12-12T10:30:49.762Z: (86c6042ed40d3a49): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-12-12T10:30:49.793Z: (86c6042ed40d34eb): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-12-12T10:30:49.815Z: (86c6042ed40d3f8d): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-12-12T10:30:49.839Z: (86c6042ed40d3a2f): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$367/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-12-12T10:30:49.863Z: (86c6042ed40d34d1): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$367/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-12-12T10:30:49.883Z: (86c6042ed40d3f73): Fusing consumer PAssert$367/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$367/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-12-12T10:30:49.909Z: (86c6042ed40d3a15): Fusing consumer PAssert$367/GroupGlobally/RewindowActuals/Window.Assign into PAssert$367/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-12-12T10:30:49.933Z: (86c6042ed40d34b7): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-12-12T10:30:49.959Z: (86c6042ed40d3f59): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) into PAssert$366/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-12-12T10:30:49.986Z: (86c6042ed40d39fb): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) into PAssert$367/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-12-12T10:30:50.018Z: (86c6042ed40d349d): Fusing consumer PAssert$367/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$367/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) [INFO] 2017-12-12T10:30:50.044Z: (86c6042ed40d3f3f): Fusing consumer Partition/ParMultiDo(Partition) into Create.Values/Read(CreateSource) [INFO] 2017-12-12T10:30:50.075Z: (86c6042ed40d39e1): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$366/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-12-12T10:30:50.115Z: (86c6042ed40d3483): Fusing consumer PAssert$366/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$366/GroupGlobally/RewindowActuals/Window.Assign [INFO] 2017-12-12T10:30:50.146Z: (86c6042ed40d3f25): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$366/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-12-12T10:30:50.174Z: (86c6042ed40d39c7): Fusing consumer PAssert$367/GroupGlobally/Window.Into()/Window.Assign into Partition/ParMultiDo(Partition) [INFO] 2017-12-12T10:30:50.206Z: (86c6042ed40d3469): Fusing consumer PAssert$366/GroupGlobally/RewindowActuals/Window.Assign into PAssert$366/GroupGlobally/GatherAllOutputs/Values/Values/Map [INFO] 2017-12-12T10:30:50.243Z: (86c6042ed40d3f0b): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-12-12T10:30:50.265Z: (86c6042ed40d39ad): Fusing consumer PAssert$366/GroupGlobally/Window.Into()/Window.Assign into Partition/ParMultiDo(Partition) [INFO] 2017-12-12T10:30:50.285Z: (86c6042ed40d344f): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-12-12T10:30:50.309Z: (86c6042ed40d3ef1): Fusing consumer PAssert$366/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$366/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) [INFO] 2017-12-12T10:30:50.339Z: (86c6042ed40d3993): Fusing consumer PAssert$366/GroupGlobally/GroupDummyAndContents/Write into PAssert$366/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-12-12T10:30:50.361Z: (86c6042ed40d3435): Fusing consumer PAssert$366/GroupGlobally/GroupDummyAndContents/Reify into PAssert$366/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-12-12T10:30:50.382Z: (86c6042ed40d3ed7): Fusing consumer PAssert$367/GroupGlobally/GroupDummyAndContents/Reify into PAssert$367/GroupGlobally/WindowIntoDummy/Window.Assign [INFO] 2017-12-12T10:30:50.405Z: (86c6042ed40d3979): Fusing consumer PAssert$367/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$367/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-12-12T10:30:50.418Z: (86c6042ed40d341b): Fusing consumer PAssert$366/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$366/GroupGlobally/Create.Values/Read(CreateSource) [INFO] 2017-12-12T10:30:50.752Z: (d5c1500c03fa0d5f): Executing operation PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-12-12T10:30:50.777Z: (9e7398e810ac4982): Executing operation PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-12-12T10:30:50.822Z: (21da7da9722fb4d): Starting 1 workers in us-central1-f... [INFO] 2017-12-12T10:30:51.005Z: (9e7398e810ac454f): Executing operation Create.Values/Read(CreateSource)+Partition/ParMultiDo(Partition)+PAssert$367/GroupGlobally/Window.Into()/Window.Assign+PAssert$367/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$367/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$367/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Write+PAssert$366/GroupGlobally/Window.Into()/Window.Assign+PAssert$366/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$366/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$366/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-12-12T10:30:58.990Z: (836cf1bc2286ccfc): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s). [INFO] 2017-12-12T10:31:03.427Z: (7c7f27198516ad5f): Executing operation WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/GroupByKey/Close [INFO] 2017-12-12T10:31:03.482Z: (e9814ce0c51a3f43): Executing operation PAssert$355/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-12-12T10:31:03.615Z: (7c7f27198516aa87): Executing operation WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/GroupByKey/Read+WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues+WindowingTest.WindowedCount/Count.PerElement/Combine.perKey(Count)/Combine.GroupedValues/Extract+WindowingTest.WindowedCount/FormatCounts+PAssert$355/GroupGlobally/Window.Into()/Window.Assign+PAssert$355/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$355/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$355/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$355/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$355/GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-12-12T10:31:06.068Z: (465de76821d27522): Workers have started successfully. [INFO] 2017-12-12T10:31:06.132Z: (4216c2486c96bce8): Workers have started successfully. [INFO] 2017-12-12T10:31:06.029Z: (5a4b5839138f53c): Workers have started successfully. [INFO] 2017-12-12T10:31:05.773Z: (e002ca2447e4783d): Workers have started successfully. [INFO] 2017-12-12T10:31:07.167Z: (3d4d2e5c7b61c77b): Workers have started successfully. [INFO] 2017-12-12T10:31:10.588Z: (7c7f27198516aa7c): Executing operation PAssert$355/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-12-12T10:31:10.637Z: (e9814ce0c51a37da): Executing operation PAssert$355/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-12-12T10:31:10.745Z: (7c7f27198516a7a4): Executing operation PAssert$355/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$355/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$355/GroupGlobally/GroupDummyAndContents/Reify+PAssert$355/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-12-12T10:31:10.768Z: (e9814ce0c51a3dee): Executing operation PAssert$355/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$355/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$355/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$355/GroupGlobally/RewindowActuals/Window.Assign+PAssert$355/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$355/GroupGlobally/GroupDummyAndContents/Reify+PAssert$355/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-12-12T10:31:14.955Z: (836cf1bc2286cd85): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s). [INFO] 2017-12-12T10:31:17.281Z: (e9814ce0c51a317f): Executing operation PAssert$355/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-12-12T10:31:17.342Z: (e9814ce0c51a3206): Executing operation PAssert$355/GroupGlobally/GroupDummyAndContents/Read+PAssert$355/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$355/GroupGlobally/Values/Values/Map+PAssert$355/GroupGlobally/ParDo(Concat)+PAssert$355/GetPane/Map+PAssert$355/RunChecks+PAssert$355/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-12-12T10:31:19.261Z: (33a5b72dcab7823f): Workers have started successfully. [INFO] 2017-12-12T10:31:21.337Z: (e77a02ec92377ed8): Cleaning up. [INFO] 2017-12-12T10:31:21.397Z: (e77a02ec92377b12): Stopping worker pool... [INFO] 2017-12-12T10:31:22.317Z: (8b2a8dafcb1d1e21): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-12T10:31:22.343Z: (8b2a8dafcb1d14e3): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-12T10:31:24.779Z: (76f30c0ea89ef793): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-12T10:31:24.801Z: (76f30c0ea89ef265): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-12-12_02_28_42-14286363789423883272 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-12_02_28_42-14286363789423883272. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-12-12_02_28_40-9301846139952357415 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-12_02_28_40-9301846139952357415. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-12-12T10:31:38.793Z: (a73576565661604b): Workers have started successfully. [INFO] 2017-12-12T10:31:38.149Z: (ea551310d16e40d7): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-12T10:31:38.182Z: (ea551310d16e4425): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] Job 2017-12-12_02_28_56-7953464861090696757 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-12_02_28_56-7953464861090696757. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-12-12T10:31:57.478Z: (e6a32d7cda2fcf68): Cleaning up. [INFO] 2017-12-12T10:31:57.521Z: (e6a32d7cda2fcb8f): Stopping worker pool... [INFO] 2017-12-12T10:31:59.256Z: (d6514218a224b78e): Cleaning up. [INFO] 2017-12-12T10:31:59.309Z: (d6514218a224b957): Stopping worker pool... [INFO] 2017-12-12T10:32:05.100Z: (9e7398e810ac4e01): Executing operation PAssert$367/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-12-12T10:32:05.132Z: (51e1b01a94c60d40): Executing operation PAssert$366/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-12-12T10:32:05.168Z: (249fc67c42f40c56): Executing operation PAssert$367/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-12-12T10:32:05.193Z: (51e1b01a94c60538): Executing operation PAssert$366/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-12-12T10:32:05.299Z: (249fc67c42f408af): 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-12T10:32:05.345Z: (51e1b01a94c60924): 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-12T10:32:05.375Z: (9e7398e810ac4890): 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-12T10:32:05.403Z: (9c21b0b1a9cb8398): 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-12T10:32:19.160Z: (9c21b0b1a9cb8de9): Executing operation PAssert$366/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-12-12T10:32:19.214Z: (9c21b0b1a9cb89b0): 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-12T10:32:19.315Z: (249fc67c42f404b3): Executing operation PAssert$367/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-12-12T10:32:19.360Z: (51e1b01a94c60613): 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-12T10:32:23.211Z: (d988671782f47ec7): Cleaning up. [INFO] 2017-12-12T10:32:23.259Z: (d988671782f4768e): Stopping worker pool... [INFO] 2017-12-12T10:32:28.366Z: (b379f0b18ed38ba5): Cleaning up. [INFO] 2017-12-12T10:32:28.411Z: (b379f0b18ed38dfa): Stopping worker pool... [INFO] 2017-12-12T10:32:28.755Z: (86c6042ed40d367c): Cleaning up. [INFO] 2017-12-12T10:32:28.819Z: (86c6042ed40d3662): Stopping worker pool... [INFO] 2017-12-12T10:32:32.916Z: (c684cf978902cbdd): Cleaning up. [INFO] 2017-12-12T10:32:34.257Z: (6026c45c598bc2f5): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-12T10:32:34.276Z: (6026c45c598bc27f): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-12T10:32:32.956Z: (c684cf978902c78c): Stopping worker pool... [INFO] Job 2017-12-12_02_29_45-3298343872609845800 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-12_02_29_45-3298343872609845800. Found 1 success, 0 failures out of 1 expected assertions. [INFO] 2017-12-12T10:33:13.905Z: (e6a32d7cda2fcf98): Worker pool stopped. [INFO] 2017-12-12T10:33:13.429Z: (d6514218a224b25e): Worker pool stopped. [INFO] 2017-12-12T10:33:17.942Z: (95580b52a31e758d): Cleaning up. [INFO] 2017-12-12T10:33:17.984Z: (95580b52a31e7c38): Stopping worker pool... [INFO] Job 2017-12-12_02_30_19-32302835751881558 finished with status DONE. [WARNING] Dataflow job 2017-12-12_02_30_19-32302835751881558 did not output a success or failure metric. [INFO] Job 2017-12-12_02_30_21-10629942224643103776 finished with status DONE. [WARNING] Dataflow job 2017-12-12_02_30_21-10629942224643103776 did not output a success or failure metric. [INFO] 2017-12-12T10:33:37.482Z: (d988671782f470f7): Worker pool stopped. [INFO] 2017-12-12T10:33:38.258Z: (836cf1bc2286c3e8): Autoscaling: Resized worker pool from 1 to 0. [INFO] 2017-12-12T10:33:38.279Z: (836cf1bc2286c4a6): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job. [INFO] 2017-12-12T10:33:43.922Z: (b379f0b18ed38235): Worker pool stopped. [INFO] Job 2017-12-12_02_30_19-12429763645419512782 finished with status DONE. [WARNING] Dataflow job 2017-12-12_02_30_19-12429763645419512782 did not output a success or failure metric. [INFO] Job 2017-12-12_02_30_42-10381080933561868896 finished with status DONE. [INFO] Success result for Dataflow job 2017-12-12_02_30_42-10381080933561868896. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-12-12T10:33:47.678Z: (c684cf978902c68d): Worker pool stopped. [INFO] Job 2017-12-12_02_30_21-3282429969969848604 finished with status DONE. [WARNING] Dataflow job 2017-12-12_02_30_21-3282429969969848604 did not output a success or failure metric. [INFO] Job 2017-12-12_02_30_19-12103866886803631548 finished with status DONE. [WARNING] Dataflow job 2017-12-12_02_30_19-12103866886803631548 did not output a success or failure metric. [INFO] 2017-12-12T10:34:31.249Z: (95580b52a31e7efd): Worker pool stopped. [INFO] Job 2017-12-12_02_30_38-11314590378521095048 finished with status DONE. [WARNING] Dataflow job 2017-12-12_02_30_38-11314590378521095048 did not output a success or failure metric. 2017-12-12T10:34:42.281 [INFO] Running org.apache.beam.sdk.transforms.ReshuffleTest 2017-12-12T10:34:42.688 [INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 245.383 s - in org.apache.beam.sdk.transforms.ReshuffleTest 2017-12-12T10:34:42.689 [INFO] Running org.apache.beam.sdk.transforms.SplittableDoFnTest 2017-12-12T10:34:42.695 [INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 287.744 s - in org.apache.beam.sdk.transforms.SplittableDoFnTest 2017-12-12T10:34:42.695 [INFO] Running org.apache.beam.sdk.transforms.PartitionTest 2017-12-12T10:34:42.708 [INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 192.59 s - in org.apache.beam.sdk.transforms.PartitionTest 2017-12-12T10:34:42.709 [INFO] Running org.apache.beam.sdk.values.PDoneTest 2017-12-12T10:34:42.727 [WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0 s - in org.apache.beam.sdk.values.PDoneTest 2017-12-12T10:34:42.728 [INFO] Running org.apache.beam.sdk.transforms.windowing.WindowingTest 2017-12-12T10:34:42.741 [INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 255.313 s - in org.apache.beam.sdk.transforms.windowing.WindowingTest 2017-12-12T10:34:42.747 [INFO] 2017-12-12T10:34:42.747 [INFO] Results: 2017-12-12T10:34:42.747 [INFO] 2017-12-12T10:34:42.748 [WARNING] Tests run: 259, Failures: 0, Errors: 0, Skipped: 1 2017-12-12T10:34:42.748 [INFO] [JENKINS] Recording test results 2017-12-12T10:34:43.733 [INFO] 2017-12-12T10:34:43.733 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only (default) @ beam-runners-google-cloud-dataflow-java --- 2017-12-12T10:34:43.910 [INFO] No dependency problems found [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [JENKINS] Archiving disabled [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-12T10:34:57.108 [INFO] ------------------------------------------------------------------------ 2017-12-12T10:34:57.108 [INFO] Reactor Summary: 2017-12-12T10:34:57.108 [INFO] 2017-12-12T10:34:57.108 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 6.183 s] 2017-12-12T10:34:57.108 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 7.506 s] 2017-12-12T10:34:57.108 [INFO] Apache Beam :: Model ............................... SUCCESS [ 1.608 s] 2017-12-12T10:34:57.108 [INFO] Apache Beam :: Model :: Pipeline ................... SUCCESS [ 8.735 s] 2017-12-12T10:34:57.108 [INFO] Apache Beam :: Model :: Job Management ............. SUCCESS [ 7.401 s] 2017-12-12T10:34:57.108 [INFO] Apache Beam :: Model :: Fn Execution ............... SUCCESS [ 9.063 s] 2017-12-12T10:34:57.108 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.402 s] 2017-12-12T10:34:57.108 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 2.241 s] 2017-12-12T10:34:57.108 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [02:02 min] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 2.327 s] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: Runners :: Local Java Core .......... SUCCESS [ 6.272 s] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [ 16.166 s] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [ 22.764 s] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [09:11 min] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 2.676 s] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 2.439 s] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [04:24 min] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 18.671 s] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [01:33 min] 2017-12-12T10:34:57.109 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:28 h] 2017-12-12T10:34:57.109 [INFO] ------------------------------------------------------------------------ 2017-12-12T10:34:57.109 [INFO] BUILD SUCCESS 2017-12-12T10:34:57.109 [INFO] ------------------------------------------------------------------------ 2017-12-12T10:34:57.109 [INFO] Total time: 01:48 h 2017-12-12T10:34:57.109 [INFO] Finished at: 2017-12-12T10:34:57+00:00 2017-12-12T10:34:59.343 [INFO] Final Memory: 387M/2456M 2017-12-12T10:34:59.343 [INFO] ------------------------------------------------------------------------ channel stopped Not sending mail to unregistered user [email protected] Not sending mail to unregistered user [email protected] Not sending mail to unregistered user [email protected] Not sending mail to unregistered user [email protected]
