See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/1/display/redirect>
------------------------------------------
[...truncated 67.16 MB...]
04/04/2018 21:39:45 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 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45 ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_OUT
04/04/2018 21:39:45 ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_ERROR
Apr 04, 2018 9:39:45 PM 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) (092c66234519bd2f28c9f1b120d61c19) switched from
RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM 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) (092c66234519bd2f28c9f1b120d61c19).
Apr 04, 2018 9:39:45 PM 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) (092c66234519bd2f28c9f1b120d61c19) [FINISHED]
Apr 04, 2018 9:39:45 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 (092c66234519bd2f28c9f1b120d61c19)
Apr 04, 2018 9:39:45 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)
(33898a90dc5185139b4d884e66af6c70) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 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)
(33898a90dc5185139b4d884e66af6c70).
Apr 04, 2018 9:39:45 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)
(33898a90dc5185139b4d884e66af6c70) [FINISHED]
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: ToKeyedWorkItem (1/1) (7c2e02e598286e6d11c673178bb780db) switched
from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 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) (092c66234519bd2f28c9f1b120d61c19) switched from
RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for ToKeyedWorkItem (1/1)
(7c2e02e598286e6d11c673178bb780db).
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem
(1/1) (7c2e02e598286e6d11c673178bb780db) [FINISHED]
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45 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/04/2018 21:39:45 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 04, 2018 9:39:45 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)
(33898a90dc5185139b4d884e66af6c70)
Apr 04, 2018 9:39:45 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) (c3455e5a1548cc4c7996354ea5c2250d) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM grizzled.slf4j.Logger info
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task ToKeyedWorkItem (7c2e02e598286e6d11c673178bb780db)
Apr 04, 2018 9:39:45 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) (c3455e5a1548cc4c7996354ea5c2250d).
Apr 04, 2018 9:39:45 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) (c3455e5a1548cc4c7996354ea5c2250d) [FINISHED]
Apr 04, 2018 9:39:45 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)
(33898a90dc5185139b4d884e66af6c70) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/1) (7c2e02e598286e6d11c673178bb780db) switched
from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45
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/04/2018 21:39:45 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 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45 ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_OUT
04/04/2018 21:39:45 ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_ERROR
Apr 04, 2018 9:39:45 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)
(c3455e5a1548cc4c7996354ea5c2250d)
Apr 04, 2018 9:39:45 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) (c3455e5a1548cc4c7996354ea5c2250d) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45 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/04/2018 21:39:45 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 04, 2018 9:39:45 PM 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)
(abfe3fb9dcd1ac98987f8b6be88b7fd9) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM 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)
(abfe3fb9dcd1ac98987f8b6be88b7fd9).
Apr 04, 2018 9:39:45 PM 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)
(abfe3fb9dcd1ac98987f8b6be88b7fd9) [FINISHED]
Apr 04, 2018 9:39:45 PM 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)
(abfe3fb9dcd1ac98987f8b6be88b7fd9)
Apr 04, 2018 9:39:45 PM 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)
(abfe3fb9dcd1ac98987f8b6be88b7fd9) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45
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/04/2018 21:39:45 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 04, 2018 9:39:45 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: ToKeyedWorkItem (1/1) (ab998d538715350af314c6840de75e90) switched
from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for ToKeyedWorkItem (1/1)
(ab998d538715350af314c6840de75e90).
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem
(1/1) (ab998d538715350af314c6840de75e90) [FINISHED]
Apr 04, 2018 9:39:45 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) (9ed32a78f8321e37cf4cf07bf2977f4a) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 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) (9ed32a78f8321e37cf4cf07bf2977f4a).
Apr 04, 2018 9:39:45 PM grizzled.slf4j.Logger info
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task ToKeyedWorkItem (ab998d538715350af314c6840de75e90)
Apr 04, 2018 9:39:45 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) (9ed32a78f8321e37cf4cf07bf2977f4a) [FINISHED]
Apr 04, 2018 9:39:45 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)
(9ed32a78f8321e37cf4cf07bf2977f4a)
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$166/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$166/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$166/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$166/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (f9275c6e900a164e00b1e91134eae682) switched from
RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
PAssert$166/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$166/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$166/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$166/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (f9275c6e900a164e00b1e91134eae682).
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
PAssert$166/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$166/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$166/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$166/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (f9275c6e900a164e00b1e91134eae682) [FINISHED]
Apr 04, 2018 9:39:45 PM grizzled.slf4j.Logger info
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$166/GroupGlobally/Window.Into()/Window.Assign.out
->
PAssert$166/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$166/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$166/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (f9275c6e900a164e00b1e91134eae682)
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/1) (ab998d538715350af314c6840de75e90) switched
from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 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) (9ed32a78f8321e37cf4cf07bf2977f4a) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$166/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$166/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$166/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$166/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (f9275c6e900a164e00b1e91134eae682) switched from
RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45 ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_OUT
04/04/2018 21:39:45 ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_ERROR
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45 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/04/2018 21:39:45 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 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45
PAssert$166/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$166/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$166/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$166/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_OUT
04/04/2018 21:39:45
PAssert$166/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$166/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$166/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$166/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_ERROR
Apr 04, 2018 9:39:45 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Apr 04, 2018 9:39:45 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) (cb2cae9c30f1d231f9a1bc58d4cc1ae2) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 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) (cb2cae9c30f1d231f9a1bc58d4cc1ae2).
Apr 04, 2018 9:39:45 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) (cb2cae9c30f1d231f9a1bc58d4cc1ae2) [FINISHED]
Apr 04, 2018 9:39:45 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)
(cb2cae9c30f1d231f9a1bc58d4cc1ae2)
Apr 04, 2018 9:39:45 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) (cb2cae9c30f1d231f9a1bc58d4cc1ae2) switched from RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM
org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job
combinetest0testsimplecombinewithcontextempty-jenkins-0404213943-318ad07f
(5c552001233814e96cfbb887df536f88) switched from state RUNNING to FINISHED.
Apr 04, 2018 9:39:45 PM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job
5c552001233814e96cfbb887df536f88
Apr 04, 2018 9:39:45 PM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45 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/04/2018 21:39:45 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 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 04/04/2018 21:39:45 Job execution switched to status FINISHED.
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_OUT
04/04/2018 21:39:45 Job execution switched to status FINISHED.
org.apache.beam.sdk.transforms.CombineTest > testSimpleCombineWithContextEmpty
STANDARD_ERROR
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClient
awaitJobResult
INFO: Job execution complete
Apr 04, 2018 9:39:45 PM
org.apache.flink.runtime.minicluster.FlinkMiniCluster stop
INFO: Stopping FlinkMiniCluster.
Apr 04, 2018 9:39:45 PM grizzled.slf4j.Logger info
INFO: Stopping TaskManager akka://flink/user/taskmanager_1#702601728.
Apr 04, 2018 9:39:45 PM grizzled.slf4j.Logger info
INFO: Disassociating from JobManager
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Apr 04, 2018 9:39:45 PM grizzled.slf4j.Logger info
INFO: Task manager akka://flink/user/taskmanager_1 wants to disconnect,
because TaskManager akka://flink/user/taskmanager_1 is disassociating.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.instance.InstanceManager
unregisterTaskManager
INFO: Unregistered task manager localhost/127.0.0.1. Number of registered
task managers 0. Number of available slots 0.
Apr 04, 2018 9:39:45 PM
org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-5a59e0d7-4c37-4210-ae69-569ff6c7a880
Apr 04, 2018 9:39:45 PM
org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
Apr 04, 2018 9:39:45 PM grizzled.slf4j.Logger info
INFO: Stopping JobManager akka://flink/user/jobmanager_1.
Apr 04, 2018 9:39:45 PM grizzled.slf4j.Logger info
INFO: Task manager akka://flink/user/taskmanager_1 is completely shut down.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:45385
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
terminate
INFO: Terminate JobClientActor.
Apr 04, 2018 9:39:45 PM org.apache.flink.runtime.client.JobClientActor
disconnectFromJobManager
INFO: Disconnect from JobManager
Actor[akka://flink/user/jobmanager_1#1790143105].
Apr 04, 2018 9:39:45 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Execution finished in 797 msecs
Apr 04, 2018 9:39:45 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Final accumulator values:
Apr 04, 2018 9:39:45 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@a6253fd
Gradle Test Executor 6 finished executing tests.
:runners:flink:validatesRunnerStreaming FAILED
:runners:flink:validatesRunnerStreaming (Thread[Task worker for ':' Thread
3,5,main]) completed. Took 8 mins 38.98 secs.
FAILURE: Build completed with 2 failures.
1: Task 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.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':runners:flink:validatesRunnerStreaming'.
> Process 'Gradle Test Executor 5' 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 18m 52s
33 actionable tasks: 33 executed
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
