(flink) branch master updated: [FLINK-35041][test] Fix the IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

[fanrui]

This is an automated email from the ASF dual-hosted git repository.

fanrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 86c8304d735 [FLINK-35041][test] Fix the 
IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
86c8304d735 is described below

commit 86c8304d735581518ce666be4896b7d5e48a1e42
Author: Rui Fan <1996fan...@gmail.com>
AuthorDate: Fri May 10 18:57:49 2024 +0800

    [FLINK-35041][test] Fix the 
IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
    
    TestingSegmentFileStateHandle object shouldn't be shared in global scope
---
 .../flink/runtime/checkpoint/metadata/CheckpointTestUtils.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/metadata/CheckpointTestUtils.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/metadata/CheckpointTestUtils.java
index 4ed3f61aa97..cb49de152fd 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/metadata/CheckpointTestUtils.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/metadata/CheckpointTestUtils.java
@@ -343,7 +343,11 @@ public class CheckpointTestUtils {
     private static StreamStateHandle createDummySegmentFileStateHandle(
             Random rnd, boolean isEmpty) {
         return isEmpty
-                ? TestingSegmentFileStateHandle.EMPTY_INSTANCE
+                ? new TestingSegmentFileStateHandle(
+                        new Path(UUID.randomUUID().toString()),
+                        0,
+                        0,
+                        CheckpointedStateScope.EXCLUSIVE)
                 : new TestingSegmentFileStateHandle(
                         new Path(String.valueOf(createRandomUUID(rnd))),
                         0,
@@ -356,10 +360,6 @@ public class CheckpointTestUtils {
 
         private static final long serialVersionUID = 1L;
 
-        private static final TestingSegmentFileStateHandle EMPTY_INSTANCE =
-                new TestingSegmentFileStateHandle(
-                        new Path("empty"), 0, 0, 
CheckpointedStateScope.EXCLUSIVE);
-
         private boolean disposed;
 
         public TestingSegmentFileStateHandle(