You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/06/26 13:37:58 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #934
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/934/display/redirect>
------------------------------------------
[...truncated 67.05 MB...]
Jun 26, 2018 1:37:55 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) (6c51c993aa862cde78475a3bf6bf3a00) [DEPLOYING].
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a) switched from CREATED to DEPLOYING.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a) [DEPLOYING]
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a) [DEPLOYING].
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a) [DEPLOYING].
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 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) (6c51c993aa862cde78475a3bf6bf3a00) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 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 26, 2018 1:37:55 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 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 26, 2018 1:37:55 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) (6c51c993aa862cde78475a3bf6bf3a00) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 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) (698f91ddbd657c06deaf503aa606e1c4) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 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 26, 2018 1:37:55 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 26, 2018 1:37:55 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) (20931c25da68f538cedab679665ec5a0) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 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) (698f91ddbd657c06deaf503aa606e1c4) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 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 26, 2018 1:37:55 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) (20931c25da68f538cedab679665ec5a0) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25) switched from CREATED to DEPLOYING.
Jun 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25) [DEPLOYING]
Jun 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25) [DEPLOYING].
Jun 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25) [DEPLOYING].
Jun 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 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 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25) switched from DEPLOYING to RUNNING.
Jun 26, 2018 1:37:55 PM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState
INFO: No restore state for UnbounedSourceWrapper.
Jun 26, 2018 1:37:55 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@3ad1e055]
Jun 26, 2018 1:37:55 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 26, 2018 1:37:55 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 26, 2018 1:37:55 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 26, 2018 1:37:55 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 26, 2018 1:37:55 PM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState
INFO: No restore state for UnbounedSourceWrapper.
Jun 26, 2018 1:37:55 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@12daa3e2]
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Jun 26, 2018 1:37:55 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) (698f91ddbd657c06deaf503aa606e1c4) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 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) (698f91ddbd657c06deaf503aa606e1c4).
Jun 26, 2018 1:37:55 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) (698f91ddbd657c06deaf503aa606e1c4) [FINISHED]
Jun 26, 2018 1:37:55 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 698f91ddbd657c06deaf503aa606e1c4.
Jun 26, 2018 1:37:55 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) (698f91ddbd657c06deaf503aa606e1c4) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 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) (20931c25da68f538cedab679665ec5a0) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 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) (20931c25da68f538cedab679665ec5a0).
Jun 26, 2018 1:37:55 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) (20931c25da68f538cedab679665ec5a0) [FINISHED]
Jun 26, 2018 1:37:55 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 20931c25da68f538cedab679665ec5a0.
Jun 26, 2018 1:37:55 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) (6c51c993aa862cde78475a3bf6bf3a00) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 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) (6c51c993aa862cde78475a3bf6bf3a00).
Jun 26, 2018 1:37:55 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) (6c51c993aa862cde78475a3bf6bf3a00) [FINISHED]
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a).
Jun 26, 2018 1:37:55 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) (20931c25da68f538cedab679665ec5a0) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a) [FINISHED]
Jun 26, 2018 1:37:55 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) 6c51c993aa862cde78475a3bf6bf3a00.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 8ae0d34a703d85af45910a2aa5e7c93a.
Jun 26, 2018 1:37:55 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) (6c51c993aa862cde78475a3bf6bf3a00) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: ToKeyedWorkItem (1/1) (8ae0d34a703d85af45910a2aa5e7c93a) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25).
Jun 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25) [FINISHED]
Jun 26, 2018 1:37:55 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) 87dbec87fdeac8e2f9a5027736386f25.
Jun 26, 2018 1:37:55 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) (87dbec87fdeac8e2f9a5027736386f25) switched from RUNNING to FINISHED.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job boundedreadfromunboundedsourcetest0testnodedup-jenkins-0626133755-40e92229 (a22f976b90681df0f8567a22e0d354fe) switched from state RUNNING to FINISHED.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job a22f976b90681df0f8567a22e0d354fe.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState
INFO: Job a22f976b90681df0f8567a22e0d354fe reached globally terminal state FINISHED.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job boundedreadfromunboundedsourcetest0testnodedup-jenkins-0626133755-40e92229(a22f976b90681df0f8567a22e0d354fe).
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job a22f976b90681df0f8567a22e0d354fe.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
INFO: Close ResourceManager connection 2dfc0183b1ca68f4bf15031eb9f978a8: JobManager is shutting down..
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
INFO: Suspending SlotPool.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection
INFO: Disconnect job manager b59cecb892be372d943f8dc9eb4c414a@akka://flink/user/jobmanager_271 for job a22f976b90681df0f8567a22e0d354fe from the resource manager.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
INFO: Stopping SlotPool.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
INFO: JobManager for job a22f976b90681df0f8567a22e0d354fe with leader id b59cecb892be372d943f8dc9eb4c414a lost leadership.
Jun 26, 2018 1:37:55 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: 88ff511906db3c0757dc08ca13ebe34e, jobId: a22f976b90681df0f8567a22e0d354fe).
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.minicluster.MiniCluster closeAsync
INFO: Shutting down Flink Mini Cluster
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
INFO: Remove job a22f976b90681df0f8567a22e0d354fe from job leader monitoring.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher akka://flink/user/dispatcherad02083a-3365-4721-8808-4b43eaf8a98f.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync
INFO: Shutting down rest endpoint.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherad02083a-3365-4721-8808-4b43eaf8a98f.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job a22f976b90681df0f8567a22e0d354fe.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager unregisterTaskManager
INFO: Unregister TaskManager 79e372cd3247d162682c14b167b501ea from the SlotManager.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job a22f976b90681df0f8567a22e0d354fe.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_270.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown
INFO: Shutting down stack trace sample coordinator.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0
INFO: Stopped dispatcher akka://flink/user/dispatcherad02083a-3365-4721-8808-4b43eaf8a98f.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory /tmp/flink-io-94a604fa-c442-4f5f-a189-a96283630ec3
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskexecutor.JobLeaderService stop
INFO: Stop job leader service.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_270.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:43911
Jun 26, 2018 1:37:55 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4
INFO: Stopped Akka RPC service.
Jun 26, 2018 1:37:55 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: Execution finished in 228 msecs
Jun 26, 2018 1:37:55 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: Final accumulator values:
Jun 26, 2018 1:37:55 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@bb4e26af
org.apache.beam.sdk.io.ReadTest > testBoundedPrimitiveDisplayData STANDARD_ERROR
Jun 26, 2018 1:37:55 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 26, 2018 1:37:55 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 26, 2018 1:37:56 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, 8 failed, 2 skipped
Finished generating test XML results (0.082 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.087 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 3,5,main]) completed. Took 2 mins 1.122 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 15m 36s
44 actionable tasks: 40 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/dnvag64b6uai6
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 ekirpichov@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user aaltay@gmail.com
Not sending mail to unregistered user jiangkai@gmail.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user sidhom@google.com
Jenkins build is back to normal :
beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #941
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/941/display/redirect?page=changes>
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #940
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/940/display/redirect?page=changes>
Changes:
[altay] improvements to fanout
------------------------------------------
[...truncated 79.70 KB...]
Compiling with error-prone compiler
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-sdks-java-fn-execution:compileJava'
:beam-sdks-java-fn-execution:compileJava (Thread[Task worker for ':',5,main]) completed. Took 9.408 secs.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':',5,main]) started.
> Task :beam-sdks-java-fn-execution:classes
Skipping task ':beam-sdks-java-fn-execution:classes' as it has no actions.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':',5,main]) completed. Took 0.0 secs.
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':',5,main]) started.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:compileJava
Build cache key for task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava' is bc285d9b1923b6128bc5ada1ce5e7cbc
Task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'.
Compiling with error-prone compiler
Packing task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'
:beam-sdks-java-extensions-google-cloud-platform-core:compileJava (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 10.808 secs.
:beam-sdks-java-extensions-google-cloud-platform-core:classes (Thread[Task worker for ':' Thread 13,5,main]) started.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:classes
Skipping task ':beam-sdks-java-extensions-google-cloud-platform-core:classes' as it has no actions.
:beam-sdks-java-extensions-google-cloud-platform-core:classes (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-extensions-google-cloud-platform-core:shadowJar (Thread[Task worker for ':' Thread 13,5,main]) started.
> Task :beam-sdks-java-core:compileTestJava
Build cache key for task ':beam-sdks-java-core:compileTestJava' is 041869390f9b6b95fa2c4655e069772d
Task ':beam-sdks-java-core:compileTestJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-core:compileTestJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-core:compileTestJava'.
Compiling with error-prone compiler
> Task :beam-sdks-java-fn-execution:shadowJar
Build cache key for task ':beam-sdks-java-fn-execution:shadowJar' is 9af4f6a8768f3095c0c9950bd24cb149
Caching disabled for task ':beam-sdks-java-fn-execution:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-fn-execution:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 3.166s [3166ms]
Average Time/Jar: 1.583s [1583.0ms]
*******************
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':',5,main]) completed. Took 3.342 secs.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:shadowJar
Build cache key for task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar' is bd921e1a0e139f456dcd29adb652d098
Caching disabled for task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 3.428s [3428ms]
Average Time/Jar: 1.714s [1714.0ms]
*******************
:beam-sdks-java-extensions-google-cloud-platform-core:shadowJar (Thread[Task worker for ':' Thread 13,5,main]) completed. Took 3.598 secs.
> Task :beam-runners-core-construction-java:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-construction-java:compileJava'
:beam-runners-core-construction-java:compileJava (Thread[Daemon worker,5,main]) completed. Took 16.976 secs.
:beam-runners-core-construction-java:classes (Thread[Daemon worker,5,main]) started.
> Task :beam-runners-core-construction-java:classes
Skipping task ':beam-runners-core-construction-java:classes' as it has no actions.
:beam-runners-core-construction-java:classes (Thread[Daemon worker,5,main]) completed. Took 0.0 secs.
:beam-runners-core-construction-java:shadowJar (Thread[Daemon worker,5,main]) started.
> Task :beam-runners-core-construction-java:shadowJar
Build cache key for task ':beam-runners-core-construction-java:shadowJar' is 6f6f2ab94c6df2a6390b935ec3683e7b
Caching disabled for task ':beam-runners-core-construction-java:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-core-construction-java:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.95s [2950ms]
Average Time/Jar: 1.475s [1475.0ms]
*******************
:beam-runners-core-construction-java:shadowJar (Thread[Daemon worker,5,main]) completed. Took 3.435 secs.
:beam-runners-core-java:compileJava (Thread[Task worker for ':' Thread 5,5,main]) started.
> Task :beam-runners-core-java:compileJava
Build cache key for task ':beam-runners-core-java:compileJava' is 457c8ba87c0edc274104e09b83591203
Task ':beam-runners-core-java:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-runners-core-java:compileJava'.
All input files are considered out-of-date for incremental task ':beam-runners-core-java:compileJava'.
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-java:compileJava'
:beam-runners-core-java:compileJava (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 10.384 secs.
:beam-runners-core-java:classes (Thread[Daemon worker,5,main]) started.
> Task :beam-runners-core-java:classes
Skipping task ':beam-runners-core-java:classes' as it has no actions.
:beam-runners-core-java:classes (Thread[Daemon worker,5,main]) completed. Took 0.0 secs.
:beam-runners-core-java:shadowJar (Thread[Daemon worker,5,main]) started.
> Task :beam-runners-core-java:shadowJar
Build cache key for task ':beam-runners-core-java:shadowJar' is 7afc7e88443db927bf43e1af198cfcd7
Caching disabled for task ':beam-runners-core-java:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-core-java:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.228s [2228ms]
Average Time/Jar: 1.114s [1114.0ms]
*******************
:beam-runners-core-java:shadowJar (Thread[Daemon worker,5,main]) completed. Took 2.591 secs.
:beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 5,5,main]) started.
> Task :beam-sdks-java-core:compileTestJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-sdks-java-core:compileTestJava'
:beam-sdks-java-core:compileTestJava (Thread[Task worker for ':' Thread 12,5,main]) completed. Took 33.645 secs.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':' Thread 12,5,main]) started.
> Task :beam-sdks-java-core:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/src/test/resources',> not found
Skipping task ':beam-sdks-java-core:processTestResources' as it has no source files and no previous output files.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':' Thread 12,5,main]) completed. Took 0.001 secs.
:beam-sdks-java-core:testClasses (Thread[Task worker for ':' Thread 12,5,main]) started.
> Task :beam-sdks-java-core:testClasses
Skipping task ':beam-sdks-java-core:testClasses' as it has no actions.
:beam-sdks-java-core:testClasses (Thread[Task worker for ':' Thread 12,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':' Thread 12,5,main]) started.
> Task :beam-sdks-java-harness:compileJava
Build cache key for task ':beam-sdks-java-harness:compileJava' is 2f5b2530041378e04ff8119c9289ca38
Task ':beam-sdks-java-harness:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-harness:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-harness:compileJava'.
Compiling with error-prone compiler
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/CombineRunners.java>:53: error: cannot find symbol
BeamUrns.getUrn(StandardPTransforms.Composites.COMBINE_GROUPED_VALUES),
^
symbol: variable COMBINE_GROUPED_VALUES
location: class Composites
Note: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java> uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
1 error
> Task :beam-sdks-java-harness:compileJava FAILED
:beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 5.212 secs.
> Task :beam-sdks-java-core:shadowTestJar
Build cache key for task ':beam-sdks-java-core:shadowTestJar' is 73319d8389820d55c1d17127ca1392de
Caching disabled for task ':beam-sdks-java-core:shadowTestJar': Caching has not been enabled for the task
Task ':beam-sdks-java-core:shadowTestJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 6 (includes project)
Total Time: 6.086s [6086ms]
Average Time/Jar: 1.0143333333333s [1014.3333333333ms]
*******************
:beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':' Thread 12,5,main]) completed. Took 8.118 secs.
:beam-runners-core-java:compileTestJava (Thread[Task worker for ':' Thread 12,5,main]) started.
> Task :beam-runners-core-java:compileTestJava
Build cache key for task ':beam-runners-core-java:compileTestJava' is 208d82a5f2de87485da05d27f5954edf
Task ':beam-runners-core-java:compileTestJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-runners-core-java:compileTestJava'.
All input files are considered out-of-date for incremental task ':beam-runners-core-java:compileTestJava'.
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-java:compileTestJava'
:beam-runners-core-java:compileTestJava (Thread[Task worker for ':' Thread 12,5,main]) completed. Took 10.452 secs.
:beam-runners-core-java:testClasses (Thread[Task worker for ':' Thread 12,5,main]) started.
> Task :beam-runners-core-java:testClasses
Skipping task ':beam-runners-core-java:testClasses' as it has no actions.
:beam-runners-core-java:testClasses (Thread[Task worker for ':' Thread 12,5,main]) completed. Took 0.0 secs.
:beam-runners-core-java:shadowTestJar (Thread[Task worker for ':' Thread 12,5,main]) started.
> Task :beam-runners-core-java:shadowTestJar
Build cache key for task ':beam-runners-core-java:shadowTestJar' is b6837cae2beb349b5807c04d47d74256
Caching disabled for task ':beam-runners-core-java:shadowTestJar': Caching has not been enabled for the task
Task ':beam-runners-core-java:shadowTestJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 1.914s [1914ms]
Average Time/Jar: 0.957s [957.0ms]
*******************
:beam-runners-core-java:shadowTestJar (Thread[Task worker for ':' Thread 12,5,main]) completed. Took 2.122 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-harness:compileJava'.
> Compilation failed with exit code 1; see the compiler error output for details.
* 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 1m 20s
36 actionable tasks: 32 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/3iuilxmlgytd2
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 daniel.o.programmer@gmail.com
Not sending mail to unregistered user apilloud@google.com
Not sending mail to unregistered user ekirpichov@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user aaltay@gmail.com
Not sending mail to unregistered user yifanzou@yifanzou-linuxworkstation.sea.corp.google.com
Not sending mail to unregistered user jiangkai@gmail.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user sidhom@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #939
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/939/display/redirect?page=changes>
Changes:
[yifanzou] [BEAM-4302] Add Jenkins job to check Beam dependencies and generate
------------------------------------------
[...truncated 86.91 KB...]
Compiling with error-prone compiler
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-sdks-java-fn-execution:compileJava'
:beam-sdks-java-fn-execution:compileJava (Thread[Task worker for ':' Thread 15,5,main]) completed. Took 6.835 secs.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':' Thread 15,5,main]) started.
> Task :beam-sdks-java-fn-execution:classes
Skipping task ':beam-sdks-java-fn-execution:classes' as it has no actions.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':' Thread 15,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 15,5,main]) started.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:compileJava
Build cache key for task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava' is f6cdb9e9f59c8a0cbed276d9f347fb1f
Task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'.
Compiling with error-prone compiler
Packing task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'
:beam-sdks-java-extensions-google-cloud-platform-core:compileJava (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 7.003 secs.
:beam-sdks-java-extensions-google-cloud-platform-core:classes (Thread[Task worker for ':' Thread 3,5,main]) started.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:classes
Skipping task ':beam-sdks-java-extensions-google-cloud-platform-core:classes' as it has no actions.
:beam-sdks-java-extensions-google-cloud-platform-core:classes (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-extensions-google-cloud-platform-core:shadowJar (Thread[Task worker for ':' Thread 3,5,main]) started.
> Task :beam-sdks-java-core:compileTestJava
Build cache key for task ':beam-sdks-java-core:compileTestJava' is 1b2ca8deaeb01d9d27e34223b32ffc2c
Task ':beam-sdks-java-core:compileTestJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-core:compileTestJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-core:compileTestJava'.
Compiling with error-prone compiler
> Task :beam-sdks-java-fn-execution:shadowJar
Build cache key for task ':beam-sdks-java-fn-execution:shadowJar' is 99de5d02b1af5b45dac38a7cfd640f99
Caching disabled for task ':beam-sdks-java-fn-execution:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-fn-execution:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.597s [2597ms]
Average Time/Jar: 1.2985s [1298.5ms]
*******************
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 15,5,main]) completed. Took 2.726 secs.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:shadowJar
Build cache key for task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar' is 398d029d822744ebbdbbca2962d0d613
Caching disabled for task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.794s [2794ms]
Average Time/Jar: 1.397s [1397.0ms]
*******************
:beam-sdks-java-extensions-google-cloud-platform-core:shadowJar (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 2.918 secs.
> Task :beam-runners-core-construction-java:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-construction-java:compileJava'
:beam-runners-core-construction-java:compileJava (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 10.788 secs.
:beam-runners-core-construction-java:classes (Thread[Task worker for ':' Thread 7,5,main]) started.
> Task :beam-runners-core-construction-java:classes
Skipping task ':beam-runners-core-construction-java:classes' as it has no actions.
:beam-runners-core-construction-java:classes (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 0.0 secs.
:beam-runners-core-construction-java:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) started.
> Task :beam-runners-core-construction-java:shadowJar
Build cache key for task ':beam-runners-core-construction-java:shadowJar' is a8a6119c1cd6fa16030e4f7d3835a446
Caching disabled for task ':beam-runners-core-construction-java:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-core-construction-java:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.059s [2059ms]
Average Time/Jar: 1.0295s [1029.5ms]
*******************
:beam-runners-core-construction-java:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 2.341 secs.
:beam-runners-core-java:compileJava (Thread[Task worker for ':' Thread 7,5,main]) started.
> Task :beam-runners-core-java:compileJava
Build cache key for task ':beam-runners-core-java:compileJava' is d6730071c38583d56cae2eed31585dcc
Task ':beam-runners-core-java:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-runners-core-java:compileJava'.
All input files are considered out-of-date for incremental task ':beam-runners-core-java:compileJava'.
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-java:compileJava'
:beam-runners-core-java:compileJava (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 7.198 secs.
:beam-runners-core-java:classes (Thread[Task worker for ':' Thread 7,5,main]) started.
> Task :beam-runners-core-java:classes
Skipping task ':beam-runners-core-java:classes' as it has no actions.
:beam-runners-core-java:classes (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 0.0 secs.
:beam-runners-core-java:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) started.
> Task :beam-runners-core-java:shadowJar
Build cache key for task ':beam-runners-core-java:shadowJar' is cd873a76945c08a36c0cf208ec3745bc
Caching disabled for task ':beam-runners-core-java:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-core-java:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 1.869s [1869ms]
Average Time/Jar: 0.9345s [934.5ms]
*******************
:beam-runners-core-java:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 2.205 secs.
:beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 7,5,main]) started.
> Task :beam-sdks-java-core:compileTestJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-sdks-java-core:compileTestJava'
:beam-sdks-java-core:compileTestJava (Thread[Task worker for ':',5,main]) completed. Took 23.047 secs.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':',5,main]) started.
> Task :beam-sdks-java-core:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/src/test/resources',> not found
Skipping task ':beam-sdks-java-core:processTestResources' as it has no source files and no previous output files.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':',5,main]) completed. Took 0.001 secs.
:beam-sdks-java-core:testClasses (Thread[Task worker for ':',5,main]) started.
> Task :beam-sdks-java-core:testClasses
Skipping task ':beam-sdks-java-core:testClasses' as it has no actions.
:beam-sdks-java-core:testClasses (Thread[Task worker for ':',5,main]) completed. Took 0.0 secs.
:beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':',5,main]) started.
> Task :beam-sdks-java-harness:compileJava
Build cache key for task ':beam-sdks-java-harness:compileJava' is 7588dbe2ca4b2e6b6f47f0511f7bc0cc
Task ':beam-sdks-java-harness:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-harness:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-harness:compileJava'.
Compiling with error-prone compiler
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/CombineRunners.java>:53: error: cannot find symbol
BeamUrns.getUrn(StandardPTransforms.Composites.COMBINE_GROUPED_VALUES),
^
symbol: variable COMBINE_GROUPED_VALUES
location: class Composites
Note: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java> uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
1 error
> Task :beam-sdks-java-harness:compileJava FAILED
:beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 4.365 secs.
> Task :beam-sdks-java-core:shadowTestJar
Build cache key for task ':beam-sdks-java-core:shadowTestJar' is 18ff9b219c37566b386d0c0c1bd34189
Caching disabled for task ':beam-sdks-java-core:shadowTestJar': Caching has not been enabled for the task
Task ':beam-sdks-java-core:shadowTestJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 6 (includes project)
Total Time: 5.841s [5841ms]
Average Time/Jar: 0.9735s [973.5ms]
*******************
:beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':',5,main]) completed. Took 7.633 secs.
:beam-runners-core-java:compileTestJava (Thread[Task worker for ':',5,main]) started.
> Task :beam-runners-core-java:compileTestJava
Build cache key for task ':beam-runners-core-java:compileTestJava' is 67301231b397b7f91767fa5482234b74
Task ':beam-runners-core-java:compileTestJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-runners-core-java:compileTestJava'.
All input files are considered out-of-date for incremental task ':beam-runners-core-java:compileTestJava'.
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-java:compileTestJava'
:beam-runners-core-java:compileTestJava (Thread[Task worker for ':',5,main]) completed. Took 7.811 secs.
:beam-runners-core-java:testClasses (Thread[Task worker for ':',5,main]) started.
> Task :beam-runners-core-java:testClasses
Skipping task ':beam-runners-core-java:testClasses' as it has no actions.
:beam-runners-core-java:testClasses (Thread[Task worker for ':',5,main]) completed. Took 0.0 secs.
:beam-runners-core-java:shadowTestJar (Thread[Task worker for ':',5,main]) started.
> Task :beam-runners-core-java:shadowTestJar
Build cache key for task ':beam-runners-core-java:shadowTestJar' is 146c3e97821dc4c4e2ec4c53a9799df3
Caching disabled for task ':beam-runners-core-java:shadowTestJar': Caching has not been enabled for the task
Task ':beam-runners-core-java:shadowTestJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 1.815s [1815ms]
Average Time/Jar: 0.9075s [907.5ms]
*******************
:beam-runners-core-java:shadowTestJar (Thread[Task worker for ':',5,main]) completed. Took 2.02 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-harness:compileJava'.
> Compilation failed with exit code 1; see the compiler error output for details.
* 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 1m 21s
36 actionable tasks: 36 executed
Publishing build scan...
https://gradle.com/s/q6haf3gcrgupu
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 daniel.o.programmer@gmail.com
Not sending mail to unregistered user apilloud@google.com
Not sending mail to unregistered user ekirpichov@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user aaltay@gmail.com
Not sending mail to unregistered user yifanzou@yifanzou-linuxworkstation.sea.corp.google.com
Not sending mail to unregistered user jiangkai@gmail.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user sidhom@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #938
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/938/display/redirect>
------------------------------------------
[...truncated 78.64 KB...]
All input files are considered out-of-date for incremental task ':beam-sdks-java-fn-execution:compileJava'.
Compiling with error-prone compiler
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-sdks-java-fn-execution:compileJava'
:beam-sdks-java-fn-execution:compileJava (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 6.015 secs.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':' Thread 9,5,main]) started.
> Task :beam-sdks-java-fn-execution:classes
Skipping task ':beam-sdks-java-fn-execution:classes' as it has no actions.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 9,5,main]) started.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:compileJava
Build cache key for task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava' is 40838b895b418d1f52ee56d7696dfbd2
Task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'.
Compiling with error-prone compiler
Packing task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'
:beam-sdks-java-extensions-google-cloud-platform-core:compileJava (Thread[Daemon worker,5,main]) completed. Took 6.677 secs.
:beam-sdks-java-extensions-google-cloud-platform-core:classes (Thread[Daemon worker,5,main]) started.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:classes
Skipping task ':beam-sdks-java-extensions-google-cloud-platform-core:classes' as it has no actions.
:beam-sdks-java-extensions-google-cloud-platform-core:classes (Thread[Daemon worker,5,main]) completed. Took 0.004 secs.
:beam-sdks-java-extensions-google-cloud-platform-core:shadowJar (Thread[Daemon worker,5,main]) started.
> Task :beam-sdks-java-core:compileTestJava
Build cache key for task ':beam-sdks-java-core:compileTestJava' is 312dfe71cc98d32ad5e83b7c32866acc
Task ':beam-sdks-java-core:compileTestJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-core:compileTestJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-core:compileTestJava'.
Compiling with error-prone compiler
> Task :beam-sdks-java-fn-execution:shadowJar
Build cache key for task ':beam-sdks-java-fn-execution:shadowJar' is cc618b3459f440ac6edc770aab7cb6b7
Caching disabled for task ':beam-sdks-java-fn-execution:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-fn-execution:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.778s [2778ms]
Average Time/Jar: 1.389s [1389.0ms]
*******************
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 2.96 secs.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:shadowJar
Build cache key for task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar' is 68bf53ce1d47ba62ee2cce991417c702
Caching disabled for task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.721s [2721ms]
Average Time/Jar: 1.3605s [1360.5ms]
*******************
:beam-sdks-java-extensions-google-cloud-platform-core:shadowJar (Thread[Daemon worker,5,main]) completed. Took 2.836 secs.
> Task :beam-runners-core-construction-java:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-construction-java:compileJava'
:beam-runners-core-construction-java:compileJava (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 9.931 secs.
:beam-runners-core-construction-java:classes (Thread[Task worker for ':' Thread 5,5,main]) started.
> Task :beam-runners-core-construction-java:classes
Skipping task ':beam-runners-core-construction-java:classes' as it has no actions.
:beam-runners-core-construction-java:classes (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 0.0 secs.
:beam-runners-core-construction-java:shadowJar (Thread[Task worker for ':' Thread 5,5,main]) started.
> Task :beam-runners-core-construction-java:shadowJar
Build cache key for task ':beam-runners-core-construction-java:shadowJar' is 8c0b51618bfa8865a76a9e445646c36f
Caching disabled for task ':beam-runners-core-construction-java:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-core-construction-java:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.233s [2233ms]
Average Time/Jar: 1.1165s [1116.5ms]
*******************
:beam-runners-core-construction-java:shadowJar (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 2.633 secs.
:beam-runners-core-java:compileJava (Thread[Task worker for ':' Thread 5,5,main]) started.
> Task :beam-runners-core-java:compileJava
Build cache key for task ':beam-runners-core-java:compileJava' is 7e8c09ff83fd64df94bccb996fea8446
Task ':beam-runners-core-java:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-runners-core-java:compileJava'.
All input files are considered out-of-date for incremental task ':beam-runners-core-java:compileJava'.
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-java:compileJava'
:beam-runners-core-java:compileJava (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 6.076 secs.
:beam-runners-core-java:classes (Thread[Task worker for ':' Thread 5,5,main]) started.
> Task :beam-runners-core-java:classes
Skipping task ':beam-runners-core-java:classes' as it has no actions.
:beam-runners-core-java:classes (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 0.0 secs.
:beam-runners-core-java:shadowJar (Thread[Task worker for ':' Thread 5,5,main]) started.
> Task :beam-runners-core-java:shadowJar
Build cache key for task ':beam-runners-core-java:shadowJar' is 44d10e71881e8f77c13df49156e28573
Caching disabled for task ':beam-runners-core-java:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-core-java:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 1.889s [1889ms]
Average Time/Jar: 0.9445s [944.5ms]
*******************
:beam-runners-core-java:shadowJar (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 2.194 secs.
:beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 5,5,main]) started.
> Task :beam-sdks-java-core:compileTestJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-sdks-java-core:compileTestJava'
:beam-sdks-java-core:compileTestJava (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 21.285 secs.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':' Thread 4,5,main]) started.
> Task :beam-sdks-java-core:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/src/test/resources',> not found
Skipping task ':beam-sdks-java-core:processTestResources' as it has no source files and no previous output files.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 0.001 secs.
:beam-sdks-java-core:testClasses (Thread[Task worker for ':' Thread 4,5,main]) started.
> Task :beam-sdks-java-core:testClasses
Skipping task ':beam-sdks-java-core:testClasses' as it has no actions.
:beam-sdks-java-core:testClasses (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':' Thread 4,5,main]) started.
> Task :beam-sdks-java-harness:compileJava
Build cache key for task ':beam-sdks-java-harness:compileJava' is 3ac25a361ffc5b3c1041f6832c2834be
Task ':beam-sdks-java-harness:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-harness:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-harness:compileJava'.
Compiling with error-prone compiler
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/CombineRunners.java>:53: error: cannot find symbol
BeamUrns.getUrn(StandardPTransforms.Composites.COMBINE_GROUPED_VALUES),
^
symbol: variable COMBINE_GROUPED_VALUES
location: class Composites
Note: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java> uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
1 error
> Task :beam-sdks-java-harness:compileJava FAILED
:beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 4.322 secs.
> Task :beam-sdks-java-core:shadowTestJar
Build cache key for task ':beam-sdks-java-core:shadowTestJar' is 0cab1a1c87efc6ae3af252bd756e2f63
Caching disabled for task ':beam-sdks-java-core:shadowTestJar': Caching has not been enabled for the task
Task ':beam-sdks-java-core:shadowTestJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 6 (includes project)
Total Time: 5.679s [5679ms]
Average Time/Jar: 0.9465s [946.5ms]
*******************
:beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 7.623 secs.
:beam-runners-core-java:compileTestJava (Thread[Task worker for ':' Thread 4,5,main]) started.
> Task :beam-runners-core-java:compileTestJava
Build cache key for task ':beam-runners-core-java:compileTestJava' is 7c3d0a253990415b31c36fa21672c9b6
Task ':beam-runners-core-java:compileTestJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-runners-core-java:compileTestJava'.
All input files are considered out-of-date for incremental task ':beam-runners-core-java:compileTestJava'.
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-java:compileTestJava'
:beam-runners-core-java:compileTestJava (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 7.064 secs.
:beam-runners-core-java:testClasses (Thread[Task worker for ':' Thread 4,5,main]) started.
> Task :beam-runners-core-java:testClasses
Skipping task ':beam-runners-core-java:testClasses' as it has no actions.
:beam-runners-core-java:testClasses (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 0.0 secs.
:beam-runners-core-java:shadowTestJar (Thread[Task worker for ':' Thread 4,5,main]) started.
> Task :beam-runners-core-java:shadowTestJar
Build cache key for task ':beam-runners-core-java:shadowTestJar' is 6022709f03be03ce8d28444d5b119941
Caching disabled for task ':beam-runners-core-java:shadowTestJar': Caching has not been enabled for the task
Task ':beam-runners-core-java:shadowTestJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 1.806s [1806ms]
Average Time/Jar: 0.903s [903.0ms]
*******************
:beam-runners-core-java:shadowTestJar (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 2.0 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-harness:compileJava'.
> Compilation failed with exit code 1; see the compiler error output for details.
* 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 1m 0s
36 actionable tasks: 32 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/pnqkrmhtdyt22
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 daniel.o.programmer@gmail.com
Not sending mail to unregistered user apilloud@google.com
Not sending mail to unregistered user ekirpichov@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user aaltay@gmail.com
Not sending mail to unregistered user jiangkai@gmail.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user sidhom@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #937
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/937/display/redirect?page=changes>
Changes:
[daniel.o.programmer] [BEAM-3708] Adding Combine component implementations to Java SDK
[daniel.o.programmer] Quick fix, removing commented out code.
------------------------------------------
[...truncated 78.92 KB...]
All input files are considered out-of-date for incremental task ':beam-sdks-java-fn-execution:compileJava'.
Compiling with error-prone compiler
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-sdks-java-fn-execution:compileJava'
:beam-sdks-java-fn-execution:compileJava (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 10.014 secs.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':' Thread 2,5,main]) started.
> Task :beam-sdks-java-fn-execution:classes
Skipping task ':beam-sdks-java-fn-execution:classes' as it has no actions.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 2,5,main]) started.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:compileJava
Build cache key for task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava' is c04f52645b52c6aefe678ee451d96524
Task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'.
Compiling with error-prone compiler
Packing task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'
:beam-sdks-java-extensions-google-cloud-platform-core:compileJava (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 10.954 secs.
:beam-sdks-java-extensions-google-cloud-platform-core:classes (Thread[Task worker for ':' Thread 7,5,main]) started.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:classes
Skipping task ':beam-sdks-java-extensions-google-cloud-platform-core:classes' as it has no actions.
:beam-sdks-java-extensions-google-cloud-platform-core:classes (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-extensions-google-cloud-platform-core:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) started.
> Task :beam-sdks-java-core:compileTestJava
Build cache key for task ':beam-sdks-java-core:compileTestJava' is 92cdbc89aaae84803b1ff8d7840dd9ff
Task ':beam-sdks-java-core:compileTestJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-core:compileTestJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-core:compileTestJava'.
Compiling with error-prone compiler
> Task :beam-sdks-java-fn-execution:shadowJar
Build cache key for task ':beam-sdks-java-fn-execution:shadowJar' is 0171c8cfc3374065bdc8ac3d62dd45b9
Caching disabled for task ':beam-sdks-java-fn-execution:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-fn-execution:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 3.119s [3119ms]
Average Time/Jar: 1.5595s [1559.5ms]
*******************
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 3.337 secs.
> Task :beam-sdks-java-extensions-google-cloud-platform-core:shadowJar
Build cache key for task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar' is b540954076dc6ec172d8053697b1aa60
Caching disabled for task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-extensions-google-cloud-platform-core:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 3.149s [3149ms]
Average Time/Jar: 1.5745s [1574.5ms]
*******************
:beam-sdks-java-extensions-google-cloud-platform-core:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 3.288 secs.
> Task :beam-runners-core-construction-java:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-construction-java:compileJava'
:beam-runners-core-construction-java:compileJava (Thread[Task worker for ':' Thread 14,5,main]) completed. Took 16.057 secs.
:beam-runners-core-construction-java:classes (Thread[Task worker for ':' Thread 14,5,main]) started.
> Task :beam-runners-core-construction-java:classes
Skipping task ':beam-runners-core-construction-java:classes' as it has no actions.
:beam-runners-core-construction-java:classes (Thread[Task worker for ':' Thread 14,5,main]) completed. Took 0.0 secs.
:beam-runners-core-construction-java:shadowJar (Thread[Task worker for ':' Thread 14,5,main]) started.
> Task :beam-runners-core-construction-java:shadowJar
Build cache key for task ':beam-runners-core-construction-java:shadowJar' is 435319f6a9995c36c4a5ebc3cc8d423a
Caching disabled for task ':beam-runners-core-construction-java:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-core-construction-java:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.799s [2799ms]
Average Time/Jar: 1.3995s [1399.5ms]
*******************
:beam-runners-core-construction-java:shadowJar (Thread[Task worker for ':' Thread 14,5,main]) completed. Took 3.186 secs.
:beam-runners-core-java:compileJava (Thread[Task worker for ':' Thread 14,5,main]) started.
> Task :beam-runners-core-java:compileJava
Build cache key for task ':beam-runners-core-java:compileJava' is d2a0e7fc87f1b44f8dd41e599f27f6ad
Task ':beam-runners-core-java:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-runners-core-java:compileJava'.
All input files are considered out-of-date for incremental task ':beam-runners-core-java:compileJava'.
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-java:compileJava'
:beam-runners-core-java:compileJava (Thread[Task worker for ':' Thread 14,5,main]) completed. Took 8.229 secs.
:beam-runners-core-java:classes (Thread[Task worker for ':' Thread 14,5,main]) started.
> Task :beam-runners-core-java:classes
Skipping task ':beam-runners-core-java:classes' as it has no actions.
:beam-runners-core-java:classes (Thread[Task worker for ':' Thread 14,5,main]) completed. Took 0.0 secs.
:beam-runners-core-java:shadowJar (Thread[Task worker for ':' Thread 14,5,main]) started.
> Task :beam-runners-core-java:shadowJar
Build cache key for task ':beam-runners-core-java:shadowJar' is e1ffe2a190100818f026abf9611f7c69
Caching disabled for task ':beam-runners-core-java:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-core-java:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.593s [2593ms]
Average Time/Jar: 1.2965s [1296.5ms]
*******************
:beam-runners-core-java:shadowJar (Thread[Task worker for ':' Thread 14,5,main]) completed. Took 2.918 secs.
:beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 14,5,main]) started.
> Task :beam-sdks-java-core:compileTestJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-sdks-java-core:compileTestJava'
:beam-sdks-java-core:compileTestJava (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 30.743 secs.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':' Thread 11,5,main]) started.
> Task :beam-sdks-java-core:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/core/src/test/resources',> not found
Skipping task ':beam-sdks-java-core:processTestResources' as it has no source files and no previous output files.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 0.001 secs.
:beam-sdks-java-core:testClasses (Thread[Task worker for ':' Thread 11,5,main]) started.
> Task :beam-sdks-java-core:testClasses
Skipping task ':beam-sdks-java-core:testClasses' as it has no actions.
:beam-sdks-java-core:testClasses (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':' Thread 11,5,main]) started.
> Task :beam-sdks-java-harness:compileJava
Build cache key for task ':beam-sdks-java-harness:compileJava' is 491e8fa07fb8fa3be05f88975ccc716c
Task ':beam-sdks-java-harness:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-harness:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-harness:compileJava'.
Compiling with error-prone compiler
<https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/CombineRunners.java>:53: error: cannot find symbol
BeamUrns.getUrn(StandardPTransforms.Composites.COMBINE_GROUPED_VALUES),
^
symbol: variable COMBINE_GROUPED_VALUES
location: class Composites
Note: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java> uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
1 error
> Task :beam-sdks-java-harness:compileJava FAILED
:beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 14,5,main]) completed. Took 5.511 secs.
> Task :beam-sdks-java-core:shadowTestJar
Build cache key for task ':beam-sdks-java-core:shadowTestJar' is e135805d085dbb5a5340b73137bc7ff9
Caching disabled for task ':beam-sdks-java-core:shadowTestJar': Caching has not been enabled for the task
Task ':beam-sdks-java-core:shadowTestJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 6 (includes project)
Total Time: 6.274s [6274ms]
Average Time/Jar: 1.0456666666666998s [1045.6666666667ms]
*******************
:beam-sdks-java-core:shadowTestJar (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 8.953 secs.
:beam-runners-core-java:compileTestJava (Thread[Task worker for ':' Thread 11,5,main]) started.
> Task :beam-runners-core-java:compileTestJava
Build cache key for task ':beam-runners-core-java:compileTestJava' is d74bd5163be2bdb4e0e8418473886745
Task ':beam-runners-core-java:compileTestJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-runners-core-java:compileTestJava'.
All input files are considered out-of-date for incremental task ':beam-runners-core-java:compileTestJava'.
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Packing task ':beam-runners-core-java:compileTestJava'
:beam-runners-core-java:compileTestJava (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 8.116 secs.
:beam-runners-core-java:testClasses (Thread[Task worker for ':' Thread 11,5,main]) started.
> Task :beam-runners-core-java:testClasses
Skipping task ':beam-runners-core-java:testClasses' as it has no actions.
:beam-runners-core-java:testClasses (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 0.0 secs.
:beam-runners-core-java:shadowTestJar (Thread[Task worker for ':' Thread 6,5,main]) started.
> Task :beam-runners-core-java:shadowTestJar
Build cache key for task ':beam-runners-core-java:shadowTestJar' is c76a8c5f82f4fac93d7db4ad27f82df2
Caching disabled for task ':beam-runners-core-java:shadowTestJar': Caching has not been enabled for the task
Task ':beam-runners-core-java:shadowTestJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.152s [2152ms]
Average Time/Jar: 1.076s [1076.0ms]
*******************
:beam-runners-core-java:shadowTestJar (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 2.387 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-harness:compileJava'.
> Compilation failed with exit code 1; see the compiler error output for details.
* 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 1m 23s
36 actionable tasks: 32 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/3qrwfzmxdzheg
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 daniel.o.programmer@gmail.com
Not sending mail to unregistered user apilloud@google.com
Not sending mail to unregistered user ekirpichov@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user aaltay@gmail.com
Not sending mail to unregistered user jiangkai@gmail.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user sidhom@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #936
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/936/display/redirect?page=changes>
Changes:
[daniel.o.programmer] [BEAM-2937] Comment Combine Grouped Values URN.
[daniel.o.programmer] [BEAM-2973] Moving CombineValues URN to different enum.
------------------------------------------
[...truncated 67.04 MB...]
Jun 26, 2018 5:44:26 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) (c7c7c6e2baf13eb3913fadf6941d9ebf) [DEPLOYING].
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f) switched from CREATED to DEPLOYING.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f) [DEPLOYING]
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f) [DEPLOYING].
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f) [DEPLOYING].
Jun 26, 2018 5:44:26 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) (ee0148d26f205ba57df89f7fc7dd6dd3) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 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) (c7c7c6e2baf13eb3913fadf6941d9ebf) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 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) (9a193e5d515cd9b47ebdf14aa90698b7) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 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 26, 2018 5:44:26 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 26, 2018 5:44:26 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 26, 2018 5:44:26 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 26, 2018 5:44:26 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 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 26, 2018 5:44:26 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) (ee0148d26f205ba57df89f7fc7dd6dd3) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 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) (c7c7c6e2baf13eb3913fadf6941d9ebf) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 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) (9a193e5d515cd9b47ebdf14aa90698b7) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903) switched from CREATED to DEPLOYING.
Jun 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903) [DEPLOYING]
Jun 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903) [DEPLOYING].
Jun 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903) [DEPLOYING].
Jun 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 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 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903) switched from DEPLOYING to RUNNING.
Jun 26, 2018 5:44:26 PM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState
INFO: No restore state for UnbounedSourceWrapper.
Jun 26, 2018 5:44:26 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@121c98e3]
Jun 26, 2018 5:44:26 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 26, 2018 5:44:26 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 26, 2018 5:44:26 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 26, 2018 5:44:26 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 26, 2018 5:44:26 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Jun 26, 2018 5:44:26 PM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState
INFO: No restore state for UnbounedSourceWrapper.
Jun 26, 2018 5:44:26 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@ecc5c60]
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Jun 26, 2018 5:44:26 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) (9a193e5d515cd9b47ebdf14aa90698b7) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 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) (9a193e5d515cd9b47ebdf14aa90698b7).
Jun 26, 2018 5:44:26 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) (9a193e5d515cd9b47ebdf14aa90698b7) [FINISHED]
Jun 26, 2018 5:44:26 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 9a193e5d515cd9b47ebdf14aa90698b7.
Jun 26, 2018 5:44:26 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) (9a193e5d515cd9b47ebdf14aa90698b7) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 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) (ee0148d26f205ba57df89f7fc7dd6dd3) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 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) (ee0148d26f205ba57df89f7fc7dd6dd3).
Jun 26, 2018 5:44:26 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) (ee0148d26f205ba57df89f7fc7dd6dd3) [FINISHED]
Jun 26, 2018 5:44:26 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 ee0148d26f205ba57df89f7fc7dd6dd3.
Jun 26, 2018 5:44:26 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) (c7c7c6e2baf13eb3913fadf6941d9ebf) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 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) (c7c7c6e2baf13eb3913fadf6941d9ebf).
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 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) (c7c7c6e2baf13eb3913fadf6941d9ebf) [FINISHED]
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f).
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f) [FINISHED]
Jun 26, 2018 5:44:26 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) c7c7c6e2baf13eb3913fadf6941d9ebf.
Jun 26, 2018 5:44:26 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) (ee0148d26f205ba57df89f7fc7dd6dd3) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem a4ee376aa53671b58c20ae9d4c1f7e8f.
Jun 26, 2018 5:44:26 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) (c7c7c6e2baf13eb3913fadf6941d9ebf) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: ToKeyedWorkItem (1/1) (a4ee376aa53671b58c20ae9d4c1f7e8f) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903).
Jun 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903) [FINISHED]
Jun 26, 2018 5:44:26 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) 6d8ed7c3472f54391f57ff9161784903.
Jun 26, 2018 5:44:26 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) (6d8ed7c3472f54391f57ff9161784903) switched from RUNNING to FINISHED.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job boundedreadfromunboundedsourcetest0testnodedup-jenkins-0626174425-74419eb5 (fbaf66862fe2174d8b181fe79a45c261) switched from state RUNNING to FINISHED.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job fbaf66862fe2174d8b181fe79a45c261.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState
INFO: Job fbaf66862fe2174d8b181fe79a45c261 reached globally terminal state FINISHED.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job boundedreadfromunboundedsourcetest0testnodedup-jenkins-0626174425-74419eb5(fbaf66862fe2174d8b181fe79a45c261).
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job fbaf66862fe2174d8b181fe79a45c261.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
INFO: Suspending SlotPool.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
INFO: Close ResourceManager connection 606ec15eaa40e6076f13c41e6e98baf9: JobManager is shutting down..
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection
INFO: Disconnect job manager 9592d11614a85f131d8c1bd5e2924198@akka://flink/user/jobmanager_271 for job fbaf66862fe2174d8b181fe79a45c261 from the resource manager.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.rpc.akka.AkkaRpcActor onReceive
INFO: The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet. Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is started.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.minicluster.MiniCluster closeAsync
INFO: Shutting down Flink Mini Cluster
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
INFO: Stopping SlotPool.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync
INFO: Shutting down rest endpoint.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher akka://flink/user/dispatcher3a17029c-7ff5-41ca-86ec-e3fd3d551889.
Jun 26, 2018 5:44:26 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: e56d05c320724d5eecb97f4a4593ead3, jobId: fbaf66862fe2174d8b181fe79a45c261).
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher3a17029c-7ff5-41ca-86ec-e3fd3d551889.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
INFO: Remove job fbaf66862fe2174d8b181fe79a45c261 from job leader monitoring.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job fbaf66862fe2174d8b181fe79a45c261.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager unregisterTaskManager
INFO: Unregister TaskManager 1cd62ddd1dd47d1301289d1ff7c6f022 from the SlotManager.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_270.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown
INFO: Shutting down stack trace sample coordinator.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0
INFO: Stopped dispatcher akka://flink/user/dispatcher3a17029c-7ff5-41ca-86ec-e3fd3d551889.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory /tmp/flink-io-c4b839bd-426a-4549-8c05-6ab728bebc62
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskexecutor.JobLeaderService stop
INFO: Stop job leader service.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_270.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:33665
Jun 26, 2018 5:44:26 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4
INFO: Stopped Akka RPC service.
Jun 26, 2018 5:44:26 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: Execution finished in 246 msecs
Jun 26, 2018 5:44:26 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: Final accumulator values:
Jun 26, 2018 5:44:26 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@e0d3b868
org.apache.beam.sdk.io.ReadTest > testBoundedPrimitiveDisplayData STANDARD_ERROR
Jun 26, 2018 5:44:26 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 26, 2018 5:44:26 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 26, 2018 5:44:26 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.143 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.14 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 10,5,main]) completed. Took 2 mins 40.78 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 12s
44 actionable tasks: 43 executed, 1 from cache
Publishing build scan...
https://gradle.com/s/sixs4epnbdxow
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 daniel.o.programmer@gmail.com
Not sending mail to unregistered user apilloud@google.com
Not sending mail to unregistered user ekirpichov@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user aaltay@gmail.com
Not sending mail to unregistered user jiangkai@gmail.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user sidhom@google.com
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #935
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/935/display/redirect?page=changes>
Changes:
[apilloud] [SQL] Don't wait on Unbounded PCollections
------------------------------------------
[...truncated 67.10 MB...]
INFO: Received task ToKeyedWorkItem (1/1).
Jun 26, 2018 4:57:54 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4) switched from CREATED to DEPLOYING.
Jun 26, 2018 4:57:54 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Creating FileSystem stream leak safety net for task ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4) [DEPLOYING]
Jun 26, 2018 4:57:54 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Loading JAR files for task ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4) [DEPLOYING].
Jun 26, 2018 4:57:54 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Registering task at network: ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4) [DEPLOYING].
Jun 26, 2018 4:57:54 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) (f8c2348917c8b1e0d78bf614c250616f) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 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) (80c8ea1ecafeef1e22e0f0dee190e427) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 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 26, 2018 4:57:54 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) (f8c2348917c8b1e0d78bf614c250616f) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 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) (c00ac9c450ebc18c387f605a98b95057) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 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 26, 2018 4:57:54 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) (80c8ea1ecafeef1e22e0f0dee190e427) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 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 26, 2018 4:57:54 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 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) (c00ac9c450ebc18c387f605a98b95057) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 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 26, 2018 4:57:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 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 26, 2018 4:57:54 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) (72f0af83f99f3f497fb44969b0ff601d) switched from CREATED to DEPLOYING.
Jun 26, 2018 4:57:54 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) (72f0af83f99f3f497fb44969b0ff601d) [DEPLOYING]
Jun 26, 2018 4:57:54 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) (72f0af83f99f3f497fb44969b0ff601d) [DEPLOYING].
Jun 26, 2018 4:57:54 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) (72f0af83f99f3f497fb44969b0ff601d) [DEPLOYING].
Jun 26, 2018 4:57:54 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) (72f0af83f99f3f497fb44969b0ff601d) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 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 26, 2018 4:57:54 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) (72f0af83f99f3f497fb44969b0ff601d) switched from DEPLOYING to RUNNING.
Jun 26, 2018 4:57:54 PM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState
INFO: No restore state for UnbounedSourceWrapper.
Jun 26, 2018 4:57:54 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@55ab21e5]
Jun 26, 2018 4:57:54 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 26, 2018 4:57:54 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 26, 2018 4:57:54 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Jun 26, 2018 4:57:54 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 26, 2018 4:57:54 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 26, 2018 4:57:54 PM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState
INFO: No restore state for UnbounedSourceWrapper.
Jun 26, 2018 4:57:54 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@229008be]
Jun 26, 2018 4:57:54 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Jun 26, 2018 4:57:55 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) (80c8ea1ecafeef1e22e0f0dee190e427) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 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) (80c8ea1ecafeef1e22e0f0dee190e427).
Jun 26, 2018 4:57:55 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) (80c8ea1ecafeef1e22e0f0dee190e427) [FINISHED]
Jun 26, 2018 4:57:55 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 80c8ea1ecafeef1e22e0f0dee190e427.
Jun 26, 2018 4:57:55 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) (80c8ea1ecafeef1e22e0f0dee190e427) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 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) (c00ac9c450ebc18c387f605a98b95057) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 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) (c00ac9c450ebc18c387f605a98b95057).
Jun 26, 2018 4:57:55 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) (c00ac9c450ebc18c387f605a98b95057) [FINISHED]
Jun 26, 2018 4:57:55 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 c00ac9c450ebc18c387f605a98b95057.
Jun 26, 2018 4:57:55 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) (f8c2348917c8b1e0d78bf614c250616f) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 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) (f8c2348917c8b1e0d78bf614c250616f).
Jun 26, 2018 4:57:55 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) (f8c2348917c8b1e0d78bf614c250616f) [FINISHED]
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO: ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4).
Jun 26, 2018 4:57:55 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) f8c2348917c8b1e0d78bf614c250616f.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4) [FINISHED]
Jun 26, 2018 4:57:55 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) (c00ac9c450ebc18c387f605a98b95057) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 6798b86169947903bd5979a33894ffe4.
Jun 26, 2018 4:57:55 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) (f8c2348917c8b1e0d78bf614c250616f) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.executiongraph.Execution transitionState
INFO: ToKeyedWorkItem (1/1) (6798b86169947903bd5979a33894ffe4) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 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) (72f0af83f99f3f497fb44969b0ff601d) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 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) (72f0af83f99f3f497fb44969b0ff601d).
Jun 26, 2018 4:57:55 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) (72f0af83f99f3f497fb44969b0ff601d) [FINISHED]
Jun 26, 2018 4:57:55 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) 72f0af83f99f3f497fb44969b0ff601d.
Jun 26, 2018 4:57:55 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) (72f0af83f99f3f497fb44969b0ff601d) switched from RUNNING to FINISHED.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
INFO: Job boundedreadfromunboundedsourcetest0testnodedup-jenkins-0626165754-ba0e7ec6 (17648ffba66e4b16dd71801d545ad3e7) switched from state RUNNING to FINISHED.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job 17648ffba66e4b16dd71801d545ad3e7.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState
INFO: Job 17648ffba66e4b16dd71801d545ad3e7 reached globally terminal state FINISHED.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job boundedreadfromunboundedsourcetest0testnodedup-jenkins-0626165754-ba0e7ec6(17648ffba66e4b16dd71801d545ad3e7).
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job 17648ffba66e4b16dd71801d545ad3e7.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection
INFO: Close ResourceManager connection d31c8b236bb3e9c954a844aefda0e13f: JobManager is shutting down..
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend
INFO: Suspending SlotPool.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection
INFO: Disconnect job manager a06a0bcc3c5cd70f33089d0ce04143cd@akka://flink/user/jobmanager_271 for job 17648ffba66e4b16dd71801d545ad3e7 from the resource manager.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop
INFO: Stopping SlotPool.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl jobManagerLostLeadership
INFO: JobManager for job 17648ffba66e4b16dd71801d545ad3e7 with leader id a06a0bcc3c5cd70f33089d0ce04143cd lost leadership.
Jun 26, 2018 4:57:55 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: f84cdd06cbbbe209a164dac6efe40ed0, jobId: 17648ffba66e4b16dd71801d545ad3e7).
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.minicluster.MiniCluster closeAsync
INFO: Shutting down Flink Mini Cluster
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob
INFO: Remove job 17648ffba66e4b16dd71801d545ad3e7 from job leader monitoring.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job 17648ffba66e4b16dd71801d545ad3e7.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher akka://flink/user/dispatcheraf0de571-76ca-4e84-895e-b8627b9e4522.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync
INFO: Shutting down rest endpoint.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcheraf0de571-76ca-4e84-895e-b8627b9e4522.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
INFO: Close JobManager connection for job 17648ffba66e4b16dd71801d545ad3e7.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown
INFO: Shutting down stack trace sample coordinator.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_270.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager unregisterTaskManager
INFO: Unregister TaskManager a09c3c5f886086484acabd44b437638a from the SlotManager.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0
INFO: Stopped dispatcher akka://flink/user/dispatcheraf0de571-76ca-4e84-895e-b8627b9e4522.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown
INFO: I/O manager removed spill file directory /tmp/flink-io-d3d063a3-1340-483f-9e41-e6039c7dd677
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown
INFO: Shutting down the network environment and its components.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskexecutor.JobLeaderService stop
INFO: Stop job leader service.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_270.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService
INFO: Stopping Akka RPC service.
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:45717
Jun 26, 2018 4:57:55 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4
INFO: Stopped Akka RPC service.
Jun 26, 2018 4:57:55 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: Execution finished in 227 msecs
Jun 26, 2018 4:57:55 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: Final accumulator values:
Jun 26, 2018 4:57:55 PM org.apache.beam.runners.flink.FlinkRunner createPipelineResult
INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@a55dbc56
org.apache.beam.sdk.io.ReadTest > testBoundedPrimitiveDisplayData STANDARD_ERROR
Jun 26, 2018 4:57:55 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 26, 2018 4:57:55 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 26, 2018 4:57:55 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, 8 failed, 2 skipped
Finished generating test XML results (0.098 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.07 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 14,5,main]) completed. Took 2 mins 0.413 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 15m 49s
44 actionable tasks: 40 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/i4wv2omq3ne3m
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 apilloud@google.com
Not sending mail to unregistered user ekirpichov@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Not sending mail to unregistered user aaltay@gmail.com
Not sending mail to unregistered user jiangkai@gmail.com
Not sending mail to unregistered user kirpichov@google.com
Not sending mail to unregistered user sidhom@google.com