This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit e25ce1247c01b441d6c1047da18143c9b0afe404 Author: 1996fanrui <[email protected]> AuthorDate: Fri Oct 28 16:31:14 2022 +0800 [FLINK-26803][checkpoint] Fix the bug of ChannelStateWriterImpl close 2 times --- .../streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java index 734e1400240..684568b6ce8 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java @@ -577,9 +577,9 @@ public class SubtaskCheckpointCoordinatorTest { @Test public void testChannelStateWriteResultLeakAndNotFailAfterCheckpointAborted() throws Exception { String taskName = "test"; + ChannelStateWriterImpl writer = + new ChannelStateWriterImpl(taskName, 0, getStreamFactoryFactory()); try (MockEnvironment mockEnvironment = MockEnvironment.builder().build(); - ChannelStateWriterImpl writer = - new ChannelStateWriterImpl(taskName, 0, getStreamFactoryFactory()); SubtaskCheckpointCoordinator coordinator = new SubtaskCheckpointCoordinatorImpl( new TestCheckpointStorageWorkerView(100),
