See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/926/display/redirect?page=changes>
Changes:
[sidhom] Add registrars for the portable runner
[sidhom] Add endpoint logging for PortableRunner
------------------------------------------
[...truncated 67.36 MB...]
INFO: Deploying PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (attempt #0) to localhost
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: ToKeyedWorkItem (1/1)
(d41ad1e00553a6e7279297b77be3fe05) [DEPLOYING].
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey
->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1).
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514) switched from CREATED to DEPLOYING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task
PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514) [DEPLOYING]
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task
PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514) [DEPLOYING].
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network:
PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514) [DEPLOYING].
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: PAssert$157/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$157/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(034fc3ec6ed5ef868eb164390c21614b) switched from DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: ToKeyedWorkItem (1/1) (d41ad1e00553a6e7279297b77be3fe05) switched
from DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.state.StateBackendLoader
fromApplicationOrConfigOrDefault
INFO: No state backend has been configured, using default (Memory /
JobManager) MemoryStateBackend (data in heap memory / checkpoints to
JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE,
maxStateSize: 5242880)
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: PAssert$157/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$157/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(034fc3ec6ed5ef868eb164390c21614b) switched from DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.state.StateBackendLoader
fromApplicationOrConfigOrDefault
INFO: No state backend has been configured, using default (Memory /
JobManager) MemoryStateBackend (data in heap memory / checkpoints to
JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE,
maxStateSize: 5242880)
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$157/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$157/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$157/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (805912e6644bb0b2d3cb275376c754a0) switched from
DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/1) (d41ad1e00553a6e7279297b77be3fe05) switched
from DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.state.StateBackendLoader
fromApplicationOrConfigOrDefault
INFO: No state backend has been configured, using default (Memory /
JobManager) MemoryStateBackend (data in heap memory / checkpoints to
JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE,
maxStateSize: 5242880)
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$157/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$157/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$157/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (805912e6644bb0b2d3cb275376c754a0) switched from
DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1).
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331) switched from CREATED to DEPLOYING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task
PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331) [DEPLOYING]
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task
PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331) [DEPLOYING].
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514) switched from DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network:
PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331) [DEPLOYING].
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.state.StateBackendLoader
fromApplicationOrConfigOrDefault
INFO: No state backend has been configured, using default (Memory /
JobManager) MemoryStateBackend (data in heap memory / checkpoints to
JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE,
maxStateSize: 5242880)
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514) switched from DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331) switched from DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.state.StateBackendLoader
fromApplicationOrConfigOrDefault
INFO: No state backend has been configured, using default (Memory /
JobManager) MemoryStateBackend (data in heap memory / checkpoints to
JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE,
maxStateSize: 5242880)
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331) switched from DEPLOYING to RUNNING.
Jun 25, 2018 11:08:58 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
Jun 25, 2018 11:08:58 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
open
INFO: Unbounded Flink Source 0/1 is reading from sources:
[org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter@3d7b1b43]
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
WARNING: The operator name
PAssert$157/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
exceeded the 80 characters length limit and was truncated.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
WARNING: The operator name
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
exceeded the 80 characters length limit and was truncated.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
WARNING: The operator name
PAssert$157/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
exceeded the 80 characters length limit and was truncated.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
WARNING: The operator name Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
exceeded the 80 characters length limit and was truncated.
Jun 25, 2018 11:08:58 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
Jun 25, 2018 11:08:58 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
open
INFO: Unbounded Flink Source 0/1 is reading from sources:
[org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter@411b5688]
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: PAssert$157/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$157/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(034fc3ec6ed5ef868eb164390c21614b) switched from RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Source:
PAssert$157/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$157/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(034fc3ec6ed5ef868eb164390c21614b).
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task Source:
PAssert$157/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$157/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(034fc3ec6ed5ef868eb164390c21614b) [FINISHED]
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source:
PAssert$157/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$157/GroupGlobally/WindowIntoDummy/Window.Assign.out
034fc3ec6ed5ef868eb164390c21614b.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: PAssert$157/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$157/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(034fc3ec6ed5ef868eb164390c21614b) switched from RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$157/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$157/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$157/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (805912e6644bb0b2d3cb275376c754a0) switched from
RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$157/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$157/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$157/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (805912e6644bb0b2d3cb275376c754a0).
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$157/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$157/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$157/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (805912e6644bb0b2d3cb275376c754a0) [FINISHED]
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$157/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$157/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$157/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem 805912e6644bb0b2d3cb275376c754a0.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514) switched from RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514).
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514) [FINISHED]
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: ToKeyedWorkItem (1/1) (d41ad1e00553a6e7279297b77be3fe05) switched
from RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$157/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$157/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$157/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (805912e6644bb0b2d3cb275376c754a0) switched from
RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for ToKeyedWorkItem (1/1)
(d41ad1e00553a6e7279297b77be3fe05).
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)
f451abde2dbdea537586938cf6d02514.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem
(1/1) (d41ad1e00553a6e7279297b77be3fe05) [FINISHED]
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task ToKeyedWorkItem d41ad1e00553a6e7279297b77be3fe05.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f451abde2dbdea537586938cf6d02514) switched from RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331) switched from RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331).
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331) [FINISHED]
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/1) (d41ad1e00553a6e7279297b77be3fe05) switched
from RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
8241e1835a8e319b4bb471a425926331.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$157/GroupGlobally/GroupDummyAndContents ->
PAssert$157/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$157/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$157/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$157/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$157/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (8241e1835a8e319b4bb471a425926331) switched from RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job
boundedreadfromunboundedsourcetest0testnodedup-jenkins-0625230857-3b6dcd52
(f8765c048d78c5377ee3547491f71615) switched from state RUNNING to FINISHED.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job
f8765c048d78c5377ee3547491f71615.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job f8765c048d78c5377ee3547491f71615 reached globally terminal state
FINISHED.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.jobmaster.JobMaster
postStop
INFO: Stopping the JobMaster for job
boundedreadfromunboundedsourcetest0testnodedup-jenkins-0625230857-3b6dcd52(f8765c048d78c5377ee3547491f71615).
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job f8765c048d78c5377ee3547491f71615.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection ee98e01b657c105f33fbb0973ae3f7e9:
JobManager is shutting down..
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
INFO: Suspending SlotPool.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
86c23b0dd078fa0e6c7d7de818af401d@akka://flink/user/jobmanager_271 for job
f8765c048d78c5377ee3547491f71615 from the resource manager.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
INFO: Stopping SlotPool.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job f8765c048d78c5377ee3547491f71615 with leader id
86c23b0dd078fa0e6c7d7de818af401d lost leadership.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
3fe0e98d99e4a57bb37102951ff12f33, jobId: f8765c048d78c5377ee3547491f71615).
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
INFO: Remove job f8765c048d78c5377ee3547491f71615 from job leader
monitoring.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcherca2ff161-0257-4381-b546-ec29ee0d9af1.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job f8765c048d78c5377ee3547491f71615.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcherca2ff161-0257-4381-b546-ec29ee0d9af1.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job f8765c048d78c5377ee3547491f71615.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager bc0bef0b0780a69b8b18d08dbc9fb180 from the
SlotManager.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_270.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcherca2ff161-0257-4381-b546-ec29ee0d9af1.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-6d9265f7-3204-4046-9d62-82c6ebd00628
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Jun 25, 2018 11:08:58 PM
org.apache.flink.runtime.taskexecutor.JobLeaderService stop
INFO: Stop job leader service.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_270.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:41345
Jun 25, 2018 11:08:58 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Jun 25, 2018 11:08:58 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 226 msecs
Jun 25, 2018 11:08:58 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Jun 25, 2018 11:08:58 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@3753b0dd
org.apache.beam.sdk.io.ReadTest > testBoundedPrimitiveDisplayData STANDARD_ERROR
Jun 25, 2018 11:08:58 PM org.apache.beam.runners.flink.FlinkRunner
fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files
from the classpath: will stage 96 files. Enable logging at DEBUG level to see
which files will be staged.
org.apache.beam.sdk.io.ReadTest > testStreamingPrimitiveDisplayData
STANDARD_ERROR
Jun 25, 2018 11:08:58 PM org.apache.beam.runners.flink.FlinkRunner
fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files
from the classpath: will stage 96 files. Enable logging at DEBUG level to see
which files will be staged.
org.apache.beam.sdk.io.AvroIOTest > testPrimitiveReadDisplayData STANDARD_ERROR
Jun 25, 2018 11:08:58 PM org.apache.beam.runners.flink.FlinkRunner
fromOptions
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files
from the classpath: will stage 96 files. Enable logging at DEBUG level to see
which files will be staged.
Gradle Test Executor 4 finished executing tests.
> Task :beam-runners-flink_2.11:validatesRunnerStreaming FAILED
230 tests completed, 8 failed, 2 skipped
Finished generating test XML results (0.103 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.116 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/reports/tests/validatesRunnerStreaming>
:beam-runners-flink_2.11:validatesRunnerStreaming (Thread[Daemon
worker,5,main]) completed. Took 2 mins 0.513 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11:validatesRunnerStreaming'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/reports/tests/validatesRunnerStreaming/index.html>
* 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.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 16m 18s
44 actionable tasks: 37 executed, 7 from cache
Publishing build scan...
https://gradle.com/s/hrfrvhovq7aiw
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
