You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2023/01/23 15:47:26 UTC
[flink] 02/03: [FLINK-26803][checkpoint] Fix the bug of ChannelStateWriterImpl close 2 times
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 <19...@gmail.com>
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),