You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2017/11/18 02:56:16 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Dataflow #4367
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4367/display/redirect?page=changes>
Changes:
[tgroh] Add a Local Java Core Module
[tgroh] Move StructuralKey to the local execution module
[tgroh] Add A TransformExecutorFactory
------------------------------------------
[...truncated 21.27 MB...]
[INFO] 2017-11-18T02:53:03.589Z: (bdef2b81b6805643): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-18T02:53:03.670Z: (20b7097deab5261d): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Read+Sum/Combine.perKey(SumInts)/Combine.GroupedValues+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract+Sum/Values/Values/Map+PAssert$325/GroupGlobally/Window.Into()/Window.Assign+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+PAssert$325/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write+PAssert$325/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$325/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-18T02:53:05.500Z: (b864bef06d9d6af): Executing operation PAssert$321/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:53:05.521Z: (b864bef06d9de6e): Executing operation PAssert$321/GroupGlobally/GroupDummyAndContents/Read+PAssert$321/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$321/GroupGlobally/Values/Values/Map+PAssert$321/GroupGlobally/ParDo(Concat)+PAssert$321/GetPane/Map+PAssert$321/RunChecks+PAssert$321/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-18T02:53:07.059Z: (b073dbfefae41d86): Cleaning up.
[INFO] 2017-11-18T02:53:07.097Z: (b073dbfefae4167c): Stopping worker pool...
[INFO] 2017-11-18T02:53:07.240Z: (549903643574a89c): Executing operation PAssert$330/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:53:07.284Z: (549903643574a277): Executing operation PAssert$330/GroupGlobally/GroupDummyAndContents/Read+PAssert$330/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$330/GroupGlobally/Values/Values/Map+PAssert$330/GroupGlobally/ParDo(Concat)+PAssert$330/GetPane/Map+PAssert$330/RunChecks+PAssert$330/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-18T02:53:08.916Z: (4254b9593244a0ff): Executing operation Combine.globally(UniqueInts)/View.AsIterable/CreateDataflowView
[INFO] 2017-11-18T02:53:09.024Z: (4254b9593244a313): Executing operation Combine.globally(UniqueInts)/CreateVoid/Read(CreateSource)+Combine.globally(UniqueInts)/ProduceDefault+PAssert$329/GroupGlobally/Window.Into()/Window.Assign+PAssert$329/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$329/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$329/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-18T02:53:09.620Z: (f349744c63fc8ec): Executing operation Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/GroupByKey/Close
[INFO] 2017-11-18T02:53:09.642Z: (f349744c63fcb84): Executing operation PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-18T02:53:09.710Z: (cf62db1387170659): Executing operation Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/GroupByKey/Read+Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/Combine.GroupedValues+Combine.globally(SumInteger)/Values/Values/Map+ParDo(GetLast)+PAssert$328/GroupGlobally/Window.Into()/Window.Assign+PAssert$328/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$328/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$328/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-18T02:53:09.704Z: (691fd40094e777ee): Executing operation Combine.perKey(MeanInts)/GroupByKey/Close
[INFO] 2017-11-18T02:53:09.725Z: (691fd40094e774c6): Executing operation Combine.globally(MeanInts)/Combine.perKey(MeanInts)/GroupByKey/Close
[INFO] 2017-11-18T02:53:09.746Z: (6d449faea7288601): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-18T02:53:09.766Z: (e02e3e0d973a52bf): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-18T02:53:09.819Z: (e02e3e0d973a5f40): Executing operation Combine.perKey(MeanInts)/GroupByKey/Read+Combine.perKey(MeanInts)/Combine.GroupedValues+Combine.perKey(MeanInts)/Combine.GroupedValues/Extract+PAssert$332/GroupGlobally/Window.Into()/Window.Assign+PAssert$332/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+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-11-18T02:53:09.838Z: (6d449faea7288058): Executing operation Combine.globally(MeanInts)/Combine.perKey(MeanInts)/GroupByKey/Read+Combine.globally(MeanInts)/Combine.perKey(MeanInts)/Combine.GroupedValues+Combine.globally(MeanInts)/Combine.perKey(MeanInts)/Combine.GroupedValues/Extract+Combine.globally(MeanInts)/Values/Values/Map+PAssert$331/GroupGlobally/Window.Into()/Window.Assign+PAssert$331/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+Combine.globally(MeanInts)/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+PAssert$331/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$331/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-18T02:53:10.220Z: (20b7097deab52899): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
[INFO] 2017-11-18T02:53:10.239Z: (bdef2b81b6805d9d): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:53:10.259Z: (bdef2b81b6805ed5): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
[INFO] 2017-11-18T02:53:10.270Z: (20b7097deab52331): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:53:10.327Z: (e2a577d69872404b): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
[INFO] 2017-11-18T02:53:10.347Z: (20b7097deab525ad): Executing operation PAssert$325/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$325/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$325/GroupGlobally/GroupDummyAndContents/Reify+PAssert$325/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:10.366Z: (bdef2b81b6805a82): Executing operation PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$325/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$325/GroupGlobally/RewindowActuals/Window.Assign+PAssert$325/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$325/GroupGlobally/GroupDummyAndContents/Reify+PAssert$325/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:12.615Z: (691fd40094e771ac): Executing operation PAssert$332/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:53:12.647Z: (691fd40094e77e84): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:53:12.726Z: (691fd40094e77ea0): 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-11-18T02:53:12.759Z: (e02e3e0d973a53b6): 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-11-18T02:53:11.079Z: (9b0f86f8898bb533): Autoscaling: Resized worker pool from 2 to 0.
[INFO] 2017-11-18T02:53:11.082Z: (9b0f86f8898bb89d): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:53:13.199Z: (549903643574a5d4): Executing operation PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:53:13.240Z: (549903643574aa3c): Executing operation PAssert$329/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:53:13.326Z: (4254b9593244a2b6): Executing operation PAssert$329/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$329/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$329/GroupGlobally/GroupDummyAndContents/Reify+PAssert$329/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:13.359Z: (549903643574ad40): Executing operation PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$329/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$329/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$329/GroupGlobally/RewindowActuals/Window.Assign+PAssert$329/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$329/GroupGlobally/GroupDummyAndContents/Reify+PAssert$329/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:16.194Z: (f349744c63fc2f9): Executing operation PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:53:16.242Z: (cf62db1387170acb): Executing operation PAssert$328/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:53:16.305Z: (cf62db1387170666): Executing operation PAssert$328/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$328/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$328/GroupGlobally/GroupDummyAndContents/Reify+PAssert$328/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:16.323Z: (f349744c63fc87c): Executing operation PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$328/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$328/GroupGlobally/RewindowActuals/Window.Assign+PAssert$328/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$328/GroupGlobally/GroupDummyAndContents/Reify+PAssert$328/GroupGlobally/GroupDummyAndContents/Write
[INFO] Job 2017-11-17_18_50_18-6213072424167007831 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_50_18-6213072424167007831. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-18T02:53:17.497Z: (549903643574ab2a): Executing operation PAssert$329/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:53:17.541Z: (549903643574a505): Executing operation PAssert$329/GroupGlobally/GroupDummyAndContents/Read+PAssert$329/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$329/GroupGlobally/Values/Values/Map+PAssert$329/GroupGlobally/ParDo(Concat)+PAssert$329/GetPane/Map+PAssert$329/RunChecks+PAssert$329/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-18T02:53:19.102Z: (691fd40094e776c3): Executing operation Combine.globally(MeanInts)/View.AsIterable/CreateDataflowView
[INFO] 2017-11-18T02:53:19.186Z: (691fd40094e77a07): Executing operation Combine.globally(MeanInts)/CreateVoid/Read(CreateSource)+Combine.globally(MeanInts)/ProduceDefault+PAssert$331/GroupGlobally/Window.Into()/Window.Assign+PAssert$331/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$331/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$331/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-18T02:53:20.786Z: (6d449faea7288c66): Executing operation PAssert$332/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:53:20.820Z: (e02e3e0d973a582c): 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-11-18T02:53:19.937Z: (34e659656fa1b2ea): Cleaning up.
[INFO] 2017-11-18T02:53:19.968Z: (34e659656fa1b060): Stopping worker pool...
[INFO] 2017-11-18T02:53:20.601Z: (51d8845548e56b66): Workers have started successfully.
[INFO] 2017-11-18T02:53:20.946Z: (bdef2b81b6805940): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:53:20.978Z: (20b7097deab5238a): Executing operation PAssert$325/GroupGlobally/GroupDummyAndContents/Read+PAssert$325/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$325/GroupGlobally/Values/Values/Map+PAssert$325/GroupGlobally/ParDo(Concat)+PAssert$325/GetPane/Map+PAssert$325/RunChecks+PAssert$325/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-18T02:53:23.693Z: (cf62db1387170814): Executing operation PAssert$328/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:53:23.725Z: (cf62db13871700eb): Executing operation PAssert$328/GroupGlobally/GroupDummyAndContents/Read+PAssert$328/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$328/GroupGlobally/Values/Values/Map+PAssert$328/GroupGlobally/ParDo(Concat)+PAssert$328/GetPane/Map+PAssert$328/RunChecks+PAssert$328/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-18T02:53:27.506Z: (6d449faea72889f9): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:53:27.537Z: (691fd40094e77bbe): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:53:27.641Z: (6d449faea7288564): Executing operation PAssert$331/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$331/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$331/GroupGlobally/GroupDummyAndContents/Reify+PAssert$331/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:27.701Z: (691fd40094e77d67): Executing operation PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$331/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$331/GroupGlobally/RewindowActuals/Window.Assign+PAssert$331/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$331/GroupGlobally/GroupDummyAndContents/Reify+PAssert$331/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:27.346Z: (aa7ecfdd444c6dfd): Cleaning up.
[INFO] 2017-11-18T02:53:27.375Z: (aa7ecfdd444c6f7b): Stopping worker pool...
[INFO] 2017-11-18T02:53:31.525Z: (c76b51d8d5468a58): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:53:31.528Z: (c76b51d8d54688e2): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:53:31.668Z: (20b7097deab52760): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
[INFO] 2017-11-18T02:53:31.716Z: (20b7097deab52aa5): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
[INFO] 2017-11-18T02:53:32.991Z: (60bdd12c3ef8e8ea): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:53:32.994Z: (60bdd12c3ef8eb70): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:53:33.714Z: (691fd40094e77a4d): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:53:33.737Z: (6d449faea72881e3): Executing operation PAssert$331/GroupGlobally/GroupDummyAndContents/Read+PAssert$331/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$331/GroupGlobally/Values/Values/Map+PAssert$331/GroupGlobally/ParDo(Concat)+PAssert$331/GetPane/Map+PAssert$331/RunChecks+PAssert$331/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-18T02:53:37.069Z: (5af451bb0f6af754): Cleaning up.
[INFO] 2017-11-18T02:53:37.116Z: (5af451bb0f6afb0e): Stopping worker pool...
[INFO] Job 2017-11-17_18_50_10-17819272244627450777 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_50_10-17819272244627450777. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-18T02:53:41.320Z: (20b7097deab52f65): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/CreateDataflowView
[INFO] 2017-11-18T02:53:41.407Z: (20b7097deab52749): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-18T02:53:41.429Z: (e2a577d698724f39): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-18T02:53:41.505Z: (bdef2b81b680544c): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.globally(TestCombineFnWithContext)/Values/Values/Map+PAssert$327/GroupGlobally/Window.Into()/Window.Assign+PAssert$327/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$327/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$327/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-18T02:53:41.539Z: (20b7097deab529c5): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+PAssert$326/GroupGlobally/Window.Into()/Window.Assign+PAssert$326/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$326/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$326/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] Job 2017-11-17_18_48_57-9047230695731020510 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_48_57-9047230695731020510. Found 1 success, 0 failures out of 1 expected assertions.
[INFO] 2017-11-18T02:53:49.124Z: (7107ae59a52fa2a7): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Close
[INFO] 2017-11-18T02:53:49.170Z: (7107ae59a52fa27e): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
[INFO] 2017-11-18T02:53:49.204Z: (25cab39104df9684): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-18T02:53:49.323Z: (25cab39104df9e87): Executing operation Sum/Combine.perKey(SumInts)/GroupByKey/Read+Sum/Combine.perKey(SumInts)/Combine.GroupedValues+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract+Sum/Values/Values/Map+Sum/View.AsIterable/ParDo(ToIsmRecordForGlobalWindow)+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write+PAssert$333/GroupGlobally/Window.Into()/Window.Assign+PAssert$333/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+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-11-18T02:53:50.747Z: (20b7097deab520e0): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:53:50.777Z: (e2a577d6987243d8): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:53:50.808Z: (20b7097deab52b78): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:53:50.854Z: (20b7097deab52610): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:53:50.885Z: (e2a577d698724af4): Executing operation PAssert$326/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$326/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$326/GroupGlobally/GroupDummyAndContents/Reify+PAssert$326/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:50.913Z: (20b7097deab526a1): Executing operation PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$326/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$326/GroupGlobally/RewindowActuals/Window.Assign+PAssert$326/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$326/GroupGlobally/GroupDummyAndContents/Reify+PAssert$326/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:50.973Z: (603dd435ab2a47c4): Executing operation PAssert$327/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$327/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$327/GroupGlobally/GroupDummyAndContents/Reify+PAssert$327/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:50.996Z: (bdef2b81b680557a): Executing operation PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$327/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$327/GroupGlobally/RewindowActuals/Window.Assign+PAssert$327/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$327/GroupGlobally/GroupDummyAndContents/Reify+PAssert$327/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-18T02:53:50.041Z: (344abde9577b9451): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:53:50.044Z: (344abde9577b9607): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:53:53.415Z: (20b7097deab52a77): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:53:53.450Z: (e2a577d698724f93): Executing operation PAssert$326/GroupGlobally/GroupDummyAndContents/Read+PAssert$326/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$326/GroupGlobally/Values/Values/Map+PAssert$326/GroupGlobally/ParDo(Concat)+PAssert$326/GetPane/Map+PAssert$326/RunChecks+PAssert$326/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-18T02:53:53.117Z: (7107ae59a52fa045): Executing operation Sum/View.AsIterable/CreateDataflowView
[INFO] 2017-11-18T02:53:53.215Z: (7107ae59a52faab9): Executing operation Sum/CreateVoid/Read(CreateSource)+Sum/ProduceDefault+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write+PAssert$333/GroupGlobally/Window.Into()/Window.Assign+PAssert$333/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+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-11-18T02:53:55.034Z: (4fb63384fc1435c9): Autoscaling: Resizing worker pool from 1 to 2.
[INFO] 2017-11-18T02:53:56.439Z: (17ad7eb347e521a8): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:53:56.441Z: (17ad7eb347e5226a): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:53:56.838Z: (bdef2b81b6805438): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:53:56.859Z: (e2a577d6987245f9): Executing operation PAssert$327/GroupGlobally/GroupDummyAndContents/Read+PAssert$327/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$327/GroupGlobally/Values/Values/Map+PAssert$327/GroupGlobally/ParDo(Concat)+PAssert$327/GetPane/Map+PAssert$327/RunChecks+PAssert$327/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-18T02:53:58.261Z: (12f468bd7842d56e): Cleaning up.
[INFO] 2017-11-18T02:53:58.287Z: (12f468bd7842d6a0): Stopping worker pool...
[INFO] Job 2017-11-17_18_50_10-17346366284371679349 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_50_10-17346366284371679349. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] 2017-11-18T02:53:56.261Z: (7107ae59a52fa6c2): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
[INFO] 2017-11-18T02:53:56.292Z: (25cab39104df9e8f): Executing operation PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:53:56.319Z: (7107ae59a52fadba): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
[INFO] 2017-11-18T02:53:56.343Z: (25cab39104df9c47): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:53:56.431Z: (25cab39104df9b24): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
[INFO] 2017-11-18T02:53:56.463Z: (af3506abe0394ea8): 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-11-18T02:53:56.494Z: (7107ae59a52faf4f): 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-11-18T02:53:59.026Z: (4dfa471ad98cab): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:53:59.028Z: (4dfa471ad98ff5): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:54:00.501Z: (bc70047d49879914): Autoscaling: Raised the number of workers to 2 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-18T02:54:01.627Z: (231de1451de9f44a): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:54:01.633Z: (231de1451de9f850): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:54:01.263Z: (21fbf83972e959a3): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:54:01.265Z: (21fbf83972e95889): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:54:01.746Z: (59c1b358df22936b): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:54:01.748Z: (59c1b358df2295f1): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-17_18_50_45-298067346394293404 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_50_45-298067346394293404. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] Job 2017-11-17_18_50_47-15004496939722591821 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_50_47-15004496939722591821. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-18T02:54:06.624Z: (af3506abe0394a8f): Executing operation PAssert$333/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:54:06.656Z: (7107ae59a52faefd): 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-11-18T02:54:07.720Z: (af3506abe039412e): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
[INFO] 2017-11-18T02:54:07.751Z: (25cab39104df9202): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSingletonView/ParDo(IsmRecordForSingularValuePerWindow)
[INFO] Job 2017-11-17_18_50_52-3894515893976534316 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_50_52-3894515893976534316. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] Job 2017-11-17_18_50_52-12944573795123285811 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_50_52-12944573795123285811. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] Job 2017-11-17_18_50_16-1332148936381854095 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_50_16-1332148936381854095. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] 2017-11-18T02:54:17.651Z: (c4702177b891f5fc): Autoscaling: Resized worker pool from 2 to 0.
[INFO] 2017-11-18T02:54:17.653Z: (c4702177b891f506): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:54:21.646Z: (25cab39104df9450): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/CreateDataflowView
[INFO] 2017-11-18T02:54:21.733Z: (7107ae59a52fa761): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create
[INFO] 2017-11-18T02:54:21.766Z: (25cab39104df9579): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Create
[INFO] 2017-11-18T02:54:21.895Z: (af3506abe0394662): Executing operation Combine.globally(TestCombineFnWithContext)/WithKeys/AddKeys/Map+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write
[INFO] 2017-11-18T02:54:21.917Z: (25cab39104df9fc6): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey/Write
[INFO] 2017-11-18T02:54:22.520Z: (7107ae59a52fafee): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close
[INFO] 2017-11-18T02:54:22.558Z: (25cab39104df9581): Executing operation PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-18T02:54:22.646Z: (25cab39104df945e): Executing operation Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+PAssert$334/GroupGlobally/Window.Into()/Window.Assign+PAssert$334/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+PAssert$334/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$334/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-18T02:54:23.805Z: (7107ae59a52fa6bd): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Close
[INFO] 2017-11-18T02:54:23.843Z: (af3506abe0394e30): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-18T02:54:23.916Z: (af3506abe0394f73): Executing operation Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.GroupedValues/Extract+Combine.globally(TestCombineFnWithContext)/Values/Values/Map+PAssert$335/GroupGlobally/Window.Into()/Window.Assign+PAssert$335/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)+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-11-18T02:54:25.700Z: (13608edd52b5c7c8): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:54:25.702Z: (13608edd52b5c65e): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-17_18_51_46-10727563927553691803 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_51_46-10727563927553691803. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-18T02:54:24.908Z: (7107ae59a52fa66b): Executing operation PAssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:54:24.940Z: (7107ae59a52fad63): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:54:25.029Z: (af3506abe03949db): 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-11-18T02:54:25.061Z: (7107ae59a52faef8): 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-11-18T02:54:26.047Z: (37a8805a5d27ac1d): Executing operation PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-18T02:54:26.078Z: (25cab39104df9b3e): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-18T02:54:26.162Z: (37a8805a5d27acc8): 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-11-18T02:54:26.192Z: (25cab39104df9a1b): 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-11-18T02:54:30.368Z: (37a8805a5d27a987): Executing operation PAssert$334/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:54:30.404Z: (25cab39104df90f9): 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-11-18T02:54:32.728Z: (af3506abe0394870): Executing operation PAssert$335/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-18T02:54:32.762Z: (37a8805a5d27a064): 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-11-18T02:54:34.167Z: (2980540bf5aadce8): Cleaning up.
[INFO] 2017-11-18T02:54:34.207Z: (2980540bf5aad29e): Stopping worker pool...
[INFO] Job 2017-11-17_18_51_43-14182084667353135204 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_51_43-14182084667353135204. Found 1 success, 0 failures out of 1 expected assertions.
[INFO] 2017-11-18T02:54:39.087Z: (65f8e47d0739c39e): Autoscaling: Resized worker pool from 2 to 0.
[INFO] 2017-11-18T02:54:39.089Z: (65f8e47d0739c750): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] 2017-11-18T02:54:39.094Z: (5af451bb0f6af006): Worker pool stopped.
[INFO] Job 2017-11-17_18_51_57-695034470301670653 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_51_57-695034470301670653. Found 2 success, 0 failures out of 2 expected assertions.
[INFO] 2017-11-18T02:54:54.744Z: (4fb459258eb8f417): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-18T02:54:54.746Z: (4fb459258eb8f361): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-17_18_51_44-11498812200228565070 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_51_44-11498812200228565070. Found 3 success, 0 failures out of 3 expected assertions.
[INFO] 2017-11-18T02:55:29.132Z: (bc70047d498791fa): Autoscaling: Resized worker pool from 2 to 0.
[INFO] 2017-11-18T02:55:29.134Z: (bc70047d49879768): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
[INFO] Job 2017-11-17_18_52_30-2419667372868453222 finished with status DONE.
[INFO] Success result for Dataflow job 2017-11-17_18_52_30-2419667372868453222. Found 3 success, 0 failures out of 3 expected assertions.
2017-11-18T02:55:38.986 [INFO] Running org.apache.beam.sdk.transforms.CombineTest
2017-11-18T02:55:39.217 [INFO] Tests run: 22, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 435.268 s - in org.apache.beam.sdk.transforms.CombineTest
2017-11-18T02:55:39.217 [INFO] Running org.apache.beam.sdk.values.PDoneTest
2017-11-18T02:55:39.224 [WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0.001 s - in org.apache.beam.sdk.values.PDoneTest
2017-11-18T02:55:39.227 [INFO]
2017-11-18T02:55:39.227 [INFO] Results:
2017-11-18T02:55:39.227 [INFO]
2017-11-18T02:55:39.227 [WARNING] Tests run: 259, Failures: 0, Errors: 0, Skipped: 1
2017-11-18T02:55:39.227 [INFO]
[JENKINS] Recording test results
2017-11-18T02:55:40.653 [INFO]
2017-11-18T02:55:40.653 [INFO] --- maven-dependency-plugin:3.0.1:analyze-only (default) @ beam-runners-google-cloud-dataflow-java ---
2017-11-18T02:55:40.844 [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-11-18T02:55:55.534 [INFO] ------------------------------------------------------------------------
2017-11-18T02:55:55.534 [INFO] Reactor Summary:
2017-11-18T02:55:55.534 [INFO]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Parent .............................. SUCCESS [ 7.427 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: SDKs :: Java :: Build Tools ......... SUCCESS [ 6.255 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Model ............................... SUCCESS [ 1.577 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Model :: Pipeline ................... SUCCESS [ 11.038 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Model :: Job Management ............. SUCCESS [ 7.733 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Model :: Fn Execution ............... SUCCESS [ 9.373 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: SDKs ................................ SUCCESS [ 2.222 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: SDKs :: Java ........................ SUCCESS [ 2.152 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: SDKs :: Java :: Core ................ SUCCESS [01:42 min]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Runners ............................. SUCCESS [ 2.408 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Runners :: Local Java Core .......... SUCCESS [ 7.613 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Runners :: Core Construction Java ... SUCCESS [ 12.887 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Runners :: Core Java ................ SUCCESS [ 31.708 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Runners :: Direct Java .............. SUCCESS [07:12 min]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: SDKs :: Java :: IO .................. SUCCESS [ 2.786 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: SDKs :: Java :: Extensions .......... SUCCESS [ 2.741 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Google Cloud Platform Core SUCCESS [ 18.777 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: SDKs :: Java :: Extensions :: Protobuf SUCCESS [ 17.826 s]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform SUCCESS [01:36 min]
2017-11-18T02:55:55.535 [INFO] Apache Beam :: Runners :: Google Cloud Dataflow .... SUCCESS [ 01:13 h]
2017-11-18T02:55:55.535 [INFO] ------------------------------------------------------------------------
2017-11-18T02:55:55.535 [INFO] BUILD SUCCESS
2017-11-18T02:55:55.535 [INFO] ------------------------------------------------------------------------
2017-11-18T02:55:55.535 [INFO] Total time: 01:27 h
2017-11-18T02:55:55.536 [INFO] Finished at: 2017-11-18T02:55:55+00:00
2017-11-18T02:55:57.039 [INFO] Final Memory: 470M/2308M
2017-11-18T02:55:57.039 [INFO] ------------------------------------------------------------------------
channel stopped
Not sending mail to unregistered user kedin@kedin-macbookpro.roam.corp.google.com
Jenkins build is back to normal :
beam_PostCommit_Java_ValidatesRunner_Dataflow #4368
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4368/display/redirect?page=changes>