See
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/521/display/redirect>
------------------------------------------
[...truncated 84.01 MB...]
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b) switched from CREATED to DEPLOYING.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task
PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b) [DEPLOYING]
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task
PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b) [DEPLOYING].
May 21, 2018 11:37:09 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/1) (9b103492f6498564a8f9d4be5286cd01) switched
from DEPLOYING to RUNNING.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f04acb4edfc663e1c825bbf07199fbfb) switched from DEPLOYING to RUNNING.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network:
PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b) [DEPLOYING].
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 05/21/2018 23:37:09 ToKeyedWorkItem(1/1) switched to RUNNING
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b) switched from DEPLOYING to RUNNING.
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_OUT
05/21/2018 23:37:09 ToKeyedWorkItem(1/1) switched to RUNNING
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_ERROR
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.state.AbstractStateBackend
loadStateBackendFromConfigOrCreateDefault
INFO: No state backend has been configured, using default state backend
(Memory / JobManager)
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 05/21/2018 23:37:09
PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1)
switched to RUNNING
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_OUT
05/21/2018 23:37:09 PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey
->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1)
switched to RUNNING
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_ERROR
May 21, 2018 11:37:09 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b) switched from DEPLOYING to RUNNING.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 05/21/2018 23:37:09 PAssert$156/GroupGlobally/GroupDummyAndContents
-> PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1)
switched to RUNNING
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_OUT
05/21/2018 23:37:09 PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1)
switched to RUNNING
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_ERROR
May 21, 2018 11:37:09 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
May 21, 2018 11:37:09 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@6a84f724]
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
WARNING: The operator name
PAssert$156/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
exceeded the 80 characters length limit and was truncated.
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
WARNING: The operator name
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
exceeded the 80 characters length limit and was truncated.
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.metrics.groups.TaskMetricGroup addOperator
WARNING: The operator name
PAssert$156/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
exceeded the 80 characters length limit and was truncated.
May 21, 2018 11:37:09 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.
May 21, 2018 11:37:09 PM
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
initializeState
INFO: No restore state for UnbounedSourceWrapper.
May 21, 2018 11:37:09 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@699fb346]
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: PAssert$156/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$156/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(f9937850757cca3ad089d0510e276147) switched from RUNNING to FINISHED.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Source:
PAssert$156/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$156/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(f9937850757cca3ad089d0510e276147).
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task Source:
PAssert$156/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$156/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(f9937850757cca3ad089d0510e276147) [FINISHED]
May 21, 2018 11:37:09 PM grizzled.slf4j.Logger info
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source:
PAssert$156/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$156/GroupGlobally/WindowIntoDummy/Window.Assign.out
(f9937850757cca3ad089d0510e276147)
May 21, 2018 11:37:09 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: PAssert$156/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$156/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1)
(f9937850757cca3ad089d0510e276147) switched from RUNNING to FINISHED.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 05/21/2018 23:37:09 Source:
PAssert$156/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$156/GroupGlobally/WindowIntoDummy/Window.Assign.out(1/1) switched to
FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_OUT
05/21/2018 23:37:09 Source:
PAssert$156/GroupGlobally/Create.Values/Read(CreateSource) ->
PAssert$156/GroupGlobally/WindowIntoDummy/Window.Assign.out(1/1) switched to
FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_ERROR
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$156/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$156/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$156/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (b4c9193ff23f1f71dccba9b718854a34) switched from
RUNNING to FINISHED.
May 21, 2018 11:37:09 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$156/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$156/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$156/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (b4c9193ff23f1f71dccba9b718854a34).
May 21, 2018 11:37:09 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$156/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$156/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$156/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (b4c9193ff23f1f71dccba9b718854a34) [FINISHED]
May 21, 2018 11:37:09 PM grizzled.slf4j.Logger info
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$156/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$156/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$156/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (b4c9193ff23f1f71dccba9b718854a34)
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f04acb4edfc663e1c825bbf07199fbfb) switched from RUNNING to FINISHED.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f04acb4edfc663e1c825bbf07199fbfb).
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f04acb4edfc663e1c825bbf07199fbfb) [FINISHED]
May 21, 2018 11:37:09 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$156/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$156/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$156/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem (1/1) (b4c9193ff23f1f71dccba9b718854a34) switched from
RUNNING to FINISHED.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: ToKeyedWorkItem (1/1) (9b103492f6498564a8f9d4be5286cd01) switched
from RUNNING to FINISHED.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for ToKeyedWorkItem (1/1)
(9b103492f6498564a8f9d4be5286cd01).
May 21, 2018 11:37:09 PM grizzled.slf4j.Logger info
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)
(f04acb4edfc663e1c825bbf07199fbfb)
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem
(1/1) (9b103492f6498564a8f9d4be5286cd01) [FINISHED]
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 05/21/2018 23:37:09 Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$156/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$156/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$156/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_OUT
05/21/2018 23:37:09 Source:
Read(TestCountingSource)/Read(AutoValue_BoundedReadFromUnboundedSource_UnboundedToBoundedSourceAdapter)
-> Read(TestCountingSource)/StripIds/ParMultiDo(StripIds) ->
PAssert$156/GroupGlobally/Window.Into()/Window.Assign.out ->
PAssert$156/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)/ParMultiDo(Anonymous)
->
PAssert$156/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign.out
-> ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_ERROR
May 21, 2018 11:37:09 PM grizzled.slf4j.Logger info
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task ToKeyedWorkItem (9b103492f6498564a8f9d4be5286cd01)
May 21, 2018 11:37:09 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/1) (9b103492f6498564a8f9d4be5286cd01) switched
from RUNNING to FINISHED.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 05/21/2018 23:37:09 ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_OUT
05/21/2018 23:37:09 ToKeyedWorkItem(1/1) switched to FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_ERROR
May 21, 2018 11:37:09 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1)
(f04acb4edfc663e1c825bbf07199fbfb) switched from RUNNING to FINISHED.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 05/21/2018 23:37:09
PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1)
switched to FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_OUT
05/21/2018 23:37:09 PAssert$156/GroupGlobally/GatherAllOutputs/GroupByKey
->
PAssert$156/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous)
-> PAssert$156/GroupGlobally/RewindowActuals/Window.Assign.out ->
PAssert$156/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous)(1/1)
switched to FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_ERROR
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b) switched from RUNNING to FINISHED.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for
PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b).
May 21, 2018 11:37:09 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b) [FINISHED]
May 21, 2018 11:37:09 PM grizzled.slf4j.Logger info
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(2098a6471966d6df1fd2ce0132014f1b)
May 21, 2018 11:37:09 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)
(1/1) (2098a6471966d6df1fd2ce0132014f1b) switched from RUNNING to FINISHED.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 05/21/2018 23:37:09 PAssert$156/GroupGlobally/GroupDummyAndContents
-> PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1)
switched to FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_OUT
05/21/2018 23:37:09 PAssert$156/GroupGlobally/GroupDummyAndContents ->
PAssert$156/GroupGlobally/Values/Values/Map/ParMultiDo(Anonymous) ->
PAssert$156/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat) ->
PAssert$156/GetPane/Map/ParMultiDo(Anonymous) ->
PAssert$156/RunChecks/ParMultiDo(GroupedValuesChecker) ->
PAssert$156/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)(1/1)
switched to FINISHED
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_ERROR
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job
boundedreadfromunboundedsourcetest0testnodedup-jenkins-0521233708-23acbc8a
(c64186bec4c2df2e7ced1423081459fc) switched from state RUNNING to FINISHED.
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job
c64186bec4c2df2e7ced1423081459fc
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
logAndPrintMessage
INFO: 05/21/2018 23:37:09 Job execution switched to status FINISHED.
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_OUT
05/21/2018 23:37:09 Job execution switched to status FINISHED.
org.apache.beam.sdk.io.BoundedReadFromUnboundedSourceTest > testNoDedup
STANDARD_ERROR
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
terminate
INFO: Terminate JobClientActor.
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClientActor
disconnectFromJobManager
INFO: Disconnect from JobManager
Actor[akka://flink/user/jobmanager_1#1397881048].
May 21, 2018 11:37:09 PM org.apache.flink.runtime.client.JobClient
awaitJobResult
INFO: Job execution complete
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.minicluster.FlinkMiniCluster stop
INFO: Stopping FlinkMiniCluster.
May 21, 2018 11:37:09 PM grizzled.slf4j.Logger info
INFO: Stopping JobManager akka://flink/user/jobmanager_1.
May 21, 2018 11:37:09 PM grizzled.slf4j.Logger info
INFO: Stopping TaskManager akka://flink/user/taskmanager_1#1171958666.
May 21, 2018 11:37:09 PM grizzled.slf4j.Logger info
INFO: Disassociating from JobManager
May 21, 2018 11:37:09 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
May 21, 2018 11:37:09 PM org.apache.flink.runtime.blob.AbstractBlobCache
close
INFO: Shutting down BLOB cache
May 21, 2018 11:37:09 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:33041
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-78920684-b310-446a-8b14-8aa256444b1f
May 21, 2018 11:37:09 PM
org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
May 21, 2018 11:37:09 PM grizzled.slf4j.Logger info
INFO: Task manager akka://flink/user/taskmanager_1 is completely shut down.
May 21, 2018 11:37:09 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Execution finished in 220 msecs
May 21, 2018 11:37:09 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Final accumulator values:
May 21, 2018 11:37:09 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@959b95e2
org.apache.beam.sdk.io.ReadTest > testBoundedPrimitiveDisplayData STANDARD_ERROR
May 21, 2018 11:37:09 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
May 21, 2018 11:37:09 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
May 21, 2018 11:37:09 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 3 finished executing tests.
> Task :beam-runners-flink_2.11:validatesRunnerStreaming FAILED
230 tests completed, 1 failed, 2 skipped
Finished generating test XML results (0.097 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.106 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[Task worker for ':'
Thread 5,5,main]) completed. Took 2 mins 3.243 secs.
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11:validatesRunnerBatch'.
> 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/validatesRunnerBatch/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.
==============================================================================
2: Task 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.7/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 8m 59s
39 actionable tasks: 35 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/zcnu32vqzj5yi
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Recording test results
