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.program...@gmail.com Not sending mail to unregistered user apill...@google.com Not sending mail to unregistered user ekirpic...@gmail.com Not sending mail to unregistered user git...@alasdairhodge.co.uk Not sending mail to unregistered user aal...@gmail.com Not sending mail to unregistered user jiang...@gmail.com Not sending mail to unregistered user kirpic...@google.com Not sending mail to unregistered user sid...@google.com