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 2018/04/05 18:29:22 UTC

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #11

See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/11/display/redirect>

------------------------------------------
[...truncated 106.46 MB...]
    04/05/2018 18:29:19	View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (23fe728b76fd27a953fa03719b7e13e6)
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	PAssert$166/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$166/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$166/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	PAssert$166/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$166/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$166/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton) -> View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton) -> View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map) (1/1) (0450691c89e9d27e887afc91ef37370e) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (23fe728b76fd27a953fa03719b7e13e6) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (2f5710083e478aebbb18bbd10caf7eb4) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (2f5710083e478aebbb18bbd10caf7eb4).
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (2f5710083e478aebbb18bbd10caf7eb4) [FINISHED]
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (2f5710083e478aebbb18bbd10caf7eb4)
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (72734a3acc2aa9a3a2e00e00d4832557) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: ToKeyedWorkItem (1/1) (a150edf85ad2f139276bb996f9ae7e0e) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (72734a3acc2aa9a3a2e00e00d4832557).
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for ToKeyedWorkItem (1/1) (a150edf85ad2f139276bb996f9ae7e0e).
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (72734a3acc2aa9a3a2e00e00d4832557) [FINISHED]
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (a150edf85ad2f139276bb996f9ae7e0e) [FINISHED]
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (2f5710083e478aebbb18bbd10caf7eb4) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (72734a3acc2aa9a3a2e00e00d4832557)
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (75f4754a8cb384d4291c63b1e5b2aad0) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (75f4754a8cb384d4291c63b1e5b2aad0).
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (75f4754a8cb384d4291c63b1e5b2aad0) [FINISHED]
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem (a150edf85ad2f139276bb996f9ae7e0e)
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (75f4754a8cb384d4291c63b1e5b2aad0)
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: ToKeyedWorkItem (1/1) (962f3f8840f87913f4e921a1b269dc66) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for ToKeyedWorkItem (1/1) (962f3f8840f87913f4e921a1b269dc66).
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (962f3f8840f87913f4e921a1b269dc66) [FINISHED]
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (72734a3acc2aa9a3a2e00e00d4832557) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: ToKeyedWorkItem (1/1) (a150edf85ad2f139276bb996f9ae7e0e) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem (962f3f8840f87913f4e921a1b269dc66)
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (75f4754a8cb384d4291c63b1e5b2aad0) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (8a1e84d5d7c8e8c4e01c7f57b24f8730) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (8a1e84d5d7c8e8c4e01c7f57b24f8730).
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (8a1e84d5d7c8e8c4e01c7f57b24f8730) [FINISHED]
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (ab4770b6aeec60dea2bcfe7f092672da) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (ab4770b6aeec60dea2bcfe7f092672da).
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (ab4770b6aeec60dea2bcfe7f092672da) [FINISHED]
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: ToKeyedWorkItem (1/1) (962f3f8840f87913f4e921a1b269dc66) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (8a1e84d5d7c8e8c4e01c7f57b24f8730)
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (a3f80e5ca72e2845868fb0f9070da445) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (a3f80e5ca72e2845868fb0f9070da445).
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (a3f80e5ca72e2845868fb0f9070da445) [FINISHED]
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (ab4770b6aeec60dea2bcfe7f092672da)
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (a3f80e5ca72e2845868fb0f9070da445)
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (ab4770b6aeec60dea2bcfe7f092672da) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (8a1e84d5d7c8e8c4e01c7f57b24f8730) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (a3f80e5ca72e2845868fb0f9070da445) switched from RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
    INFO: Job combinetest0testsimplecombinewithcontextempty-jenkins-0405182918-233fb6df (ccc817e2d7cd0dd0e70db4d865ac1a5f) switched from state RUNNING to FINISHED.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/05/2018 18:29:19	Job execution switched to status FINISHED.

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/05/2018 18:29:19	Job execution switched to status FINISHED.

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
    INFO: Stopping checkpoint coordinator for job ccc817e2d7cd0dd0e70db4d865ac1a5f
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
    INFO: Shutting down
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClient awaitJobResult
    INFO: Job execution complete
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.minicluster.FlinkMiniCluster stop
    INFO: Stopping FlinkMiniCluster.
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Stopping TaskManager akka://flink/user/taskmanager_1#-1372742257.
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Stopping JobManager akka://flink/user/jobmanager_1.
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Disassociating from JobManager
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor terminate
    INFO: Terminate JobClientActor.
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.client.JobClientActor disconnectFromJobManager
    INFO: Disconnect from JobManager Actor[akka://flink/user/jobmanager_1#422408961].
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.blob.BlobServer close
    INFO: Stopped BLOB server at 0.0.0.0:41492
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
    INFO: I/O manager removed spill file directory /tmp/flink-io-08cf501c-121e-410f-8429-c14090d6ad9f
    Apr 05, 2018 6:29:19 PM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
    INFO: Shutting down the network environment and its components.
    Apr 05, 2018 6:29:19 PM grizzled.slf4j.Logger info
    INFO: Task manager akka://flink/user/taskmanager_1 is completely shut down.
    Apr 05, 2018 6:29:19 PM org.apache.beam.runners.flink.FlinkRunner run
    INFO: Execution finished in 320 msecs
    Apr 05, 2018 6:29:19 PM org.apache.beam.runners.flink.FlinkRunner run
    INFO: Final accumulator values:
    Apr 05, 2018 6:29:19 PM org.apache.beam.runners.flink.FlinkRunner run
    INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@fc6a15c2
Gradle Test Executor 8 finished executing tests.
Finished generating test XML results (0.553 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.661 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/reports/tests/validatesRunnerStreaming>
:runners:flink:validatesRunnerStreaming (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 4 mins 32.007 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':runners:flink:validatesRunnerBatch'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 1

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.5.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 10m 27s
33 actionable tasks: 33 executed
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #13

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/13/display/redirect?page=changes>


Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #12

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/12/display/redirect>

------------------------------------------
[...truncated 105.04 MB...]
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (95f648bff24437939087dadfd073d400) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (95f648bff24437939087dadfd073d400).
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (95f648bff24437939087dadfd073d400) [FINISHED]
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (1c07c281c0d981d964b40c16e8ba6844) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (1c07c281c0d981d964b40c16e8ba6844).
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem (78117b56ac816b7a8e3ab915e746c634)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (1c07c281c0d981d964b40c16e8ba6844) [FINISHED]
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (b6c98bb27557a32bba36550b54eb4273) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1e82505b65ddccfe5ab27738b60195ee)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton) -> View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/1) (e6c5b7129b4a43fd6a77153d45f89ae6) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton) -> View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton) -> View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map) (1/1) (b232754fac34278db292019c74eb1ca7) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (b6c98bb27557a32bba36550b54eb4273).
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map) (1/1) (b232754fac34278db292019c74eb1ca7).
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem (09e9b022466aae1b4d4241804168ca5b)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map) (1/1) (b232754fac34278db292019c74eb1ca7) [FINISHED]
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (b6c98bb27557a32bba36550b54eb4273) [FINISHED]
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (95f648bff24437939087dadfd073d400)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: ToKeyedWorkItem (1/1) (f956abbd24ef5e351a6848adf7e7989f) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (66ade0a004f449f2870a7aee5941dfe5) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (66ade0a004f449f2870a7aee5941dfe5).
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1c07c281c0d981d964b40c16e8ba6844)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (66ade0a004f449f2870a7aee5941dfe5) [FINISHED]
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map) (b232754fac34278db292019c74eb1ca7)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: ToKeyedWorkItem (1/1) (78117b56ac816b7a8e3ab915e746c634) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (b6c98bb27557a32bba36550b54eb4273)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (66ade0a004f449f2870a7aee5941dfe5)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (7c414669c10d156a75b72beee1a0052d) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	PAssert$168/GroupGlobally/GroupDummyAndContents -> PAssert$168/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$168/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$168/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$168/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (8b890d2b322da5fd7ecf86e19bf6f308) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (8b890d2b322da5fd7ecf86e19bf6f308).
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (8b890d2b322da5fd7ecf86e19bf6f308) [FINISHED]
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task transitionState
    INFO: PAssert$166/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$166/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$166/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (5895edda8732487809c845ce1ac9aaba) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (1e82505b65ddccfe5ab27738b60195ee) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Freeing task resources for PAssert$166/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$166/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$166/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (5895edda8732487809c845ce1ac9aaba).
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.taskmanager.Task run
    INFO: Ensuring all FileSystem streams are closed for task PAssert$166/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$166/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$166/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (5895edda8732487809c845ce1ac9aaba) [FINISHED]
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (8b890d2b322da5fd7ecf86e19bf6f308)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	PAssert$168/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$168/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$168/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$166/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$166/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$166/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (5895edda8732487809c845ce1ac9aaba)
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: ToKeyedWorkItem (1/1) (09e9b022466aae1b4d4241804168ca5b) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (95f648bff24437939087dadfd073d400) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (1c07c281c0d981d964b40c16e8ba6844) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	PAssert$167/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$167/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$167/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	Combine.perKey(TestCombineFnWithContext) -> PAssert$167/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$167/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map) (1/1) (b232754fac34278db292019c74eb1ca7) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate) -> View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous) -> (Map, Map)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem (1/1) (b6c98bb27557a32bba36550b54eb4273) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (66ade0a004f449f2870a7aee5941dfe5) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext) -> Combine.globally(TestCombineFnWithContext)/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/Window.Into()/Window.Assign.out -> PAssert$168/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous) -> PAssert$168/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out -> ToKeyedWorkItem(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	PAssert$167/GroupGlobally/GroupDummyAndContents -> PAssert$167/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$167/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$167/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$167/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$167/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude) (1/1) (8b890d2b322da5fd7ecf86e19bf6f308) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState
    INFO: PAssert$166/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$166/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$166/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (5895edda8732487809c845ce1ac9aaba) switched from RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	PAssert$166/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$166/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$166/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	PAssert$166/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$166/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$166/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
    INFO: Job combinetest0testsimplecombinewithcontextempty-jenkins-0406001426-f04c1c29 (f86fce61379fcc594b754eff0a889ee0) switched from state RUNNING to FINISHED.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	PAssert$166/GroupGlobally/GroupDummyAndContents -> PAssert$166/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$166/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) -> PAssert$166/GetPane/Map/ParMultiDo(Anonymous) -> PAssert$166/RunChecks/ParMultiDo(GroupedValuesChecker) -> PAssert$166/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1) switched to FINISHED 

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
    INFO: Stopping checkpoint coordinator for job f86fce61379fcc594b754eff0a889ee0
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor logAndPrintMessage
    INFO: 04/06/2018 00:14:27	Job execution switched to status FINISHED.

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_OUT
    04/06/2018 00:14:27	Job execution switched to status FINISHED.

org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty STANDARD_ERROR
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
    INFO: Shutting down
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor terminate
    INFO: Terminate JobClientActor.
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClientActor disconnectFromJobManager
    INFO: Disconnect from JobManager Actor[akka://flink/user/jobmanager_1#1727919096].
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.client.JobClient awaitJobResult
    INFO: Job execution complete
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.minicluster.FlinkMiniCluster stop
    INFO: Stopping FlinkMiniCluster.
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Stopping JobManager akka://flink/user/jobmanager_1.
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Stopping TaskManager akka://flink/user/taskmanager_1#-352387348.
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Disassociating from JobManager
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.blob.AbstractBlobCache close
    INFO: Shutting down BLOB cache
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.blob.BlobServer close
    INFO: Stopped BLOB server at 0.0.0.0:37133
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
    INFO: I/O manager removed spill file directory /tmp/flink-io-7b951fcb-0ba8-47a2-b17a-380aa56d55b6
    Apr 06, 2018 12:14:27 AM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
    INFO: Shutting down the network environment and its components.
    Apr 06, 2018 12:14:27 AM grizzled.slf4j.Logger info
    INFO: Task manager akka://flink/user/taskmanager_1 is completely shut down.
    Apr 06, 2018 12:14:27 AM org.apache.beam.runners.flink.FlinkRunner run
    INFO: Execution finished in 425 msecs
    Apr 06, 2018 12:14:27 AM org.apache.beam.runners.flink.FlinkRunner run
    INFO: Final accumulator values:
    Apr 06, 2018 12:14:27 AM org.apache.beam.runners.flink.FlinkRunner run
    INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@dad51882
Gradle Test Executor 6 finished executing tests.
Finished generating test XML results (0.554 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/test-results/validatesRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.73 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/reports/tests/validatesRunnerStreaming>
:runners:flink:validatesRunnerStreaming (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 3 mins 51.084 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':runners:flink:validatesRunnerBatch'.
> Process 'Gradle Test Executor 4' finished with non-zero exit value 137

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.5.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 11m 42s
33 actionable tasks: 33 executed
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure