[flink] branch master updated: [FLINK-31418][network][tests] Fix unstable test case SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout

[yingjie]

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

yingjie 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 f949fe4eb1b [FLINK-31418][network][tests] Fix unstable test case 
SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout
f949fe4eb1b is described below

commit f949fe4eb1b83a324b9139d41a6db5976a8db539
Author: Yuxin Tan <tanyuxinw...@gmail.com>
AuthorDate: Tue Mar 14 17:52:39 2023 +0800

    [FLINK-31418][network][tests] Fix unstable test case 
SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout
    
    This closes #22173.
---
 .../network/partition/SortMergeResultPartitionReadSchedulerTest.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
index 0288cfa982a..6a0528152bb 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java
@@ -266,16 +266,16 @@ class SortMergeResultPartitionReadSchedulerTest {
         SortMergeResultPartitionReadScheduler readScheduler =
                 new SortMergeResultPartitionReadScheduler(
                         bufferPool, executorService, this, 
bufferRequestTimeout);
+        long startTimestamp = System.currentTimeMillis();
         readScheduler.createSubpartitionReader(
                 new NoOpBufferAvailablityListener(), 0, partitionedFile);
         // request and use all buffers of buffer pool.
         readScheduler.run();
 
         assertThat(bufferPool.getAvailableBuffers()).isZero();
-        long startTimestamp = System.currentTimeMillis();
         
assertThatThrownBy(readScheduler::allocateBuffers).isInstanceOf(TimeoutException.class);
         long requestDuration = System.currentTimeMillis() - startTimestamp;
-        assertThat(requestDuration > bufferRequestTimeout.toMillis()).isTrue();
+        assertThat(requestDuration >= 
bufferRequestTimeout.toMillis()).isTrue();
 
         readScheduler.release();
     }