See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/929/display/redirect?page=changes>
Changes: [aaltay] [BEAM-4333] Add integration tests for python mobile games (#5747) ------------------------------------------ [...truncated 67.13 MB...] Jun 26, 2018 1:10:27 AM 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) (c38c3e61ef729080718b58295120efd9) switched from CREATED to DEPLOYING. Jun 26, 2018 1:10:27 AM 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) (c38c3e61ef729080718b58295120efd9) [DEPLOYING] Jun 26, 2018 1:10:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Loading JAR files 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) (ce2b9e5786814f76622dfb9e9781df41) [DEPLOYING]. Jun 26, 2018 1:10:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Registering task at network: 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) (ce2b9e5786814f76622dfb9e9781df41) [DEPLOYING]. Jun 26, 2018 1:10:27 AM 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) (c38c3e61ef729080718b58295120efd9) [DEPLOYING]. Jun 26, 2018 1:10:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Loading JAR files for task ToKeyedWorkItem (1/1) (03b360d71709756e91870bad95475bfb) [DEPLOYING]. Jun 26, 2018 1:10:27 AM 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) (c38c3e61ef729080718b58295120efd9) [DEPLOYING]. Jun 26, 2018 1:10:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Registering task at network: ToKeyedWorkItem (1/1) (03b360d71709756e91870bad95475bfb) [DEPLOYING]. Jun 26, 2018 1:10:27 AM 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) (c38c3e61ef729080718b58295120efd9) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM 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:10:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Loading JAR files for task Source: PAssert$157/GroupGlobally/Create.Values/Read(CreateSource) -> PAssert$157/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1) (b64e85a86a2c93599d0329e36bae06ca) [DEPLOYING]. Jun 26, 2018 1:10:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Registering task at network: Source: PAssert$157/GroupGlobally/Create.Values/Read(CreateSource) -> PAssert$157/GroupGlobally/WindowIntoDummy/Window.Assign.out (1/1) (b64e85a86a2c93599d0329e36bae06ca) [DEPLOYING]. Jun 26, 2018 1:10:27 AM org.apache.flink.runtime.taskmanager.Task run INFO: Loading JAR files for task PAssert$157/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$157/GroupGlobally/GatherAllOutputs/Values/Values/Map/ParMultiDo(Anonymous) -> PAssert$157/GroupGlobally/RewindowActuals/Window.Assign.out -> PAssert$157/GroupGlobally/KeyForDummy/AddKeys/Map/ParMultiDo(Anonymous) (1/1) (135480355046b0ab566e00ae5882c08d) [DEPLOYING]. Jun 26, 2018 1:10:27 AM 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) (135480355046b0ab566e00ae5882c08d) [DEPLOYING]. Jun 26, 2018 1:10:27 AM 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) (c38c3e61ef729080718b58295120efd9) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init> INFO: Initializing heap keyed state backend with stream factory. Jun 26, 2018 1:10:27 AM 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) (135480355046b0ab566e00ae5882c08d) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM 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:10:27 AM 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) (135480355046b0ab566e00ae5882c08d) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM 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) (b64e85a86a2c93599d0329e36bae06ca) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM 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:10:27 AM 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) (b64e85a86a2c93599d0329e36bae06ca) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState INFO: No restore state for UnbounedSourceWrapper. Jun 26, 2018 1:10:27 AM 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@1149033d] Jun 26, 2018 1:10:27 AM 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:10:27 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO: ToKeyedWorkItem (1/1) (03b360d71709756e91870bad95475bfb) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM 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:10:27 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: ToKeyedWorkItem (1/1) (03b360d71709756e91870bad95475bfb) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM 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) (ce2b9e5786814f76622dfb9e9781df41) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM 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:10:27 AM 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) (ce2b9e5786814f76622dfb9e9781df41) switched from DEPLOYING to RUNNING. Jun 26, 2018 1:10:27 AM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init> INFO: Initializing heap keyed state backend with stream factory. Jun 26, 2018 1:10:27 AM 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:10:27 AM 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:10:27 AM 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:10:27 AM org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper initializeState INFO: No restore state for UnbounedSourceWrapper. Jun 26, 2018 1:10:27 AM 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@414f2748] Jun 26, 2018 1:10:28 AM 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) (b64e85a86a2c93599d0329e36bae06ca) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM 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) (b64e85a86a2c93599d0329e36bae06ca). Jun 26, 2018 1:10:28 AM 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) (b64e85a86a2c93599d0329e36bae06ca) [FINISHED] Jun 26, 2018 1:10:28 AM 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 b64e85a86a2c93599d0329e36bae06ca. Jun 26, 2018 1:10:28 AM 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) (b64e85a86a2c93599d0329e36bae06ca) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM 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) (ce2b9e5786814f76622dfb9e9781df41) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM 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) (ce2b9e5786814f76622dfb9e9781df41). Jun 26, 2018 1:10:28 AM 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) (ce2b9e5786814f76622dfb9e9781df41) [FINISHED] Jun 26, 2018 1:10:28 AM 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 ce2b9e5786814f76622dfb9e9781df41. Jun 26, 2018 1:10:28 AM 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) (ce2b9e5786814f76622dfb9e9781df41) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM 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) (135480355046b0ab566e00ae5882c08d) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM 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) (135480355046b0ab566e00ae5882c08d). Jun 26, 2018 1:10:28 AM 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) (135480355046b0ab566e00ae5882c08d) [FINISHED] Jun 26, 2018 1:10:28 AM 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) 135480355046b0ab566e00ae5882c08d. Jun 26, 2018 1:10:28 AM 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) (135480355046b0ab566e00ae5882c08d) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO: ToKeyedWorkItem (1/1) (03b360d71709756e91870bad95475bfb) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskmanager.Task run INFO: Freeing task resources for ToKeyedWorkItem (1/1) (03b360d71709756e91870bad95475bfb). Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskmanager.Task run INFO: Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (03b360d71709756e91870bad95475bfb) [FINISHED] Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState INFO: Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 03b360d71709756e91870bad95475bfb. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO: ToKeyedWorkItem (1/1) (03b360d71709756e91870bad95475bfb) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM 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) (c38c3e61ef729080718b58295120efd9) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM 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) (c38c3e61ef729080718b58295120efd9). Jun 26, 2018 1:10:28 AM 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) (c38c3e61ef729080718b58295120efd9) [FINISHED] Jun 26, 2018 1:10:28 AM 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) c38c3e61ef729080718b58295120efd9. Jun 26, 2018 1:10:28 AM 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) (c38c3e61ef729080718b58295120efd9) switched from RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState INFO: Job boundedreadfromunboundedsourcetest0testnodedup-jenkins-0626011026-25b11c34 (92ccc8f4ef4f3445019bb099c1a730b9) switched from state RUNNING to FINISHED. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown INFO: Stopping checkpoint coordinator for job 92ccc8f4ef4f3445019bb099c1a730b9. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown INFO: Shutting down Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.dispatcher.Dispatcher jobReachedGloballyTerminalState INFO: Job 92ccc8f4ef4f3445019bb099c1a730b9 reached globally terminal state FINISHED. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.jobmaster.JobMaster postStop INFO: Stopping the JobMaster for job boundedreadfromunboundedsourcetest0testnodedup-jenkins-0626011026-25b11c34(92ccc8f4ef4f3445019bb099c1a730b9). Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.jobmaster.JobMaster dissolveResourceManagerConnection INFO: Close ResourceManager connection d3c277e20bda5926fa79b4ed5a9e37ea: JobManager is shutting down.. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool suspend INFO: Suspending SlotPool. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.jobmaster.slotpool.SlotPool postStop INFO: Stopping SlotPool. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.minicluster.MiniCluster closeAsync INFO: Shutting down Flink Mini Cluster Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection INFO: Close JobManager connection for job 92ccc8f4ef4f3445019bb099c1a730b9. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.rest.RestServerEndpoint closeAsync INFO: Shutting down rest endpoint. Jun 26, 2018 1:10:28 AM 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: 66dadec8f9e82f3e648a65836b400397, jobId: 92ccc8f4ef4f3445019bb099c1a730b9). Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskexecutor.JobLeaderService removeJob INFO: Remove job 92ccc8f4ef4f3445019bb099c1a730b9 from job leader monitoring. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection INFO: Close JobManager connection for job 92ccc8f4ef4f3445019bb099c1a730b9. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop INFO: Stopping TaskExecutor akka://flink/user/taskmanager_270. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown INFO: Shutting down TaskExecutorLocalStateStoresManager. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.dispatcher.Dispatcher postStop INFO: Stopping dispatcher akka://flink/user/dispatcherd5b44782-3862-44d4-aafe-a96edc745444. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.dispatcher.Dispatcher terminateJobManagerRunners INFO: Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherd5b44782-3862-44d4-aafe-a96edc745444. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.resourcemanager.ResourceManager closeJobManagerConnection INFO: Disconnect job manager 827d71f22fb0115145b1eb4601fe494e@akka://flink/user/jobmanager_271 for job 92ccc8f4ef4f3445019bb099c1a730b9 from the resource manager. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close INFO: Closing the SlotManager. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend INFO: Suspending the SlotManager. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager unregisterTaskManager INFO: Unregister TaskManager 8cd92fa322060f920a32721694b69ca3 from the SlotManager. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.io.disk.iomanager.IOManager shutdown INFO: I/O manager removed spill file directory /tmp/flink-io-2a9e2e0f-610b-4e59-9ef5-2a19fc12f38f Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.io.network.NetworkEnvironment shutdown INFO: Shutting down the network environment and its components. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskexecutor.JobLeaderService stop INFO: Stop job leader service. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.taskexecutor.TaskExecutor postStop INFO: Stopped TaskExecutor akka://flink/user/taskmanager_270. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator shutDown INFO: Shutting down stack trace sample coordinator. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$postStop$0 INFO: Stopped dispatcher akka://flink/user/dispatcherd5b44782-3862-44d4-aafe-a96edc745444. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint lambda$shutDownInternal$4 INFO: Removing cache directory /tmp/flink-web-ui Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService INFO: Stopping Akka RPC service. Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.blob.AbstractBlobCache close INFO: Shutting down BLOB cache Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.blob.AbstractBlobCache close INFO: Shutting down BLOB cache Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.blob.BlobServer close INFO: Stopped BLOB server at 0.0.0.0:44483 Jun 26, 2018 1:10:28 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$4 INFO: Stopped Akka RPC service. Jun 26, 2018 1:10:28 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: Execution finished in 461 msecs Jun 26, 2018 1:10:28 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: Final accumulator values: Jun 26, 2018 1:10:28 AM org.apache.beam.runners.flink.FlinkRunner createPipelineResult INFO: __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@62943f3c org.apache.beam.sdk.io.ReadTest > testBoundedPrimitiveDisplayData STANDARD_ERROR Jun 26, 2018 1:10:28 AM 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:10:28 AM 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:10:29 AM 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 230 tests completed, 8 failed, 2 skipped Finished generating test XML results (0.705 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.457 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/ws/src/runners/flink/build/reports/tests/validatesRunnerStreaming> > Task :beam-runners-flink_2.11:validatesRunnerStreaming FAILED :beam-runners-flink_2.11:validatesRunnerStreaming (Thread[Task worker for ':' Thread 12,5,main]) completed. Took 4 mins 11.496 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 19m 47s 44 actionable tasks: 40 executed, 4 from cache Publishing build scan... https://gradle.com/s/vjbflagdmj6bo 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 ekirpic...@gmail.com Not sending mail to unregistered user aal...@gmail.com Not sending mail to unregistered user kirpic...@google.com Not sending mail to unregistered user sid...@google.com