(flink) branch master updated: [FLINK-35597][test] Fix unstable LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts

[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 bc5c4b867f6 [FLINK-35597][test] Fix unstable 
LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts
bc5c4b867f6 is described below

commit bc5c4b867f65f87ad8661ac8821c6dc87af41dd9
Author: Yubin Li <lixin58...@163.com>
AuthorDate: Fri Jun 14 09:44:08 2024 +0800

    [FLINK-35597][test] Fix unstable 
LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts
---
 .../test/java/org/apache/flink/core/io/LocatableSplitAssignerTest.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-core/src/test/java/org/apache/flink/core/io/LocatableSplitAssignerTest.java
 
b/flink-core/src/test/java/org/apache/flink/core/io/LocatableSplitAssignerTest.java
index 02ef5413874..c34b5631825 100644
--- 
a/flink-core/src/test/java/org/apache/flink/core/io/LocatableSplitAssignerTest.java
+++ 
b/flink-core/src/test/java/org/apache/flink/core/io/LocatableSplitAssignerTest.java
@@ -428,7 +428,7 @@ class LocatableSplitAssignerTest {
         assertThat(ia.getNextInputSplit("testhost", 0)).isNull();
 
         // at least one fraction of hosts needs be local, no matter how bad 
the thread races
-        assertThat(ia.getNumberOfRemoteAssignments())
+        assertThat(ia.getNumberOfLocalAssignments())
                 .isGreaterThanOrEqualTo(NUM_SPLITS / hosts.length);
     }