(shardingsphere) branch master updated: Fix SimpleMemoryPipelineChannelTest.assertFetchRecordsTimeoutCorrectly in nightly CI (#29455)

[azexin]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 6e6707720c9 Fix 
SimpleMemoryPipelineChannelTest.assertFetchRecordsTimeoutCorrectly in nightly 
CI (#29455)
6e6707720c9 is described below

commit 6e6707720c9367ec8f084cfdfa607417ae9052ab
Author: Hongsheng Zhong <zhonghongsh...@apache.org>
AuthorDate: Tue Dec 19 20:24:23 2023 +0800

    Fix SimpleMemoryPipelineChannelTest.assertFetchRecordsTimeoutCorrectly in 
nightly CI (#29455)
---
 .../ingest/channel/memory/SimpleMemoryPipelineChannelTest.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/SimpleMemoryPipelineChannelTest.java
 
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/SimpleMemoryPipelineChannelTest.java
index 506f3f188d8..e99fdb4fef2 100644
--- 
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/SimpleMemoryPipelineChannelTest.java
+++ 
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/memory/SimpleMemoryPipelineChannelTest.java
@@ -48,13 +48,13 @@ class SimpleMemoryPipelineChannelTest {
     @Test
     void assertFetchRecordsTimeoutCorrectly() {
         SimpleMemoryPipelineChannel channel = new 
SimpleMemoryPipelineChannel(10, new EmptyAckCallback());
-        long startMills = System.currentTimeMillis();
+        long startMillis = System.currentTimeMillis();
         channel.fetchRecords(1, 1, TimeUnit.MILLISECONDS);
-        long delta = System.currentTimeMillis() - startMills;
+        long delta = System.currentTimeMillis() - startMillis;
         assertTrue(delta >= 1 && delta < 50, "Delta is not in [1,50) : " + 
delta);
-        startMills = System.currentTimeMillis();
+        startMillis = System.currentTimeMillis();
         channel.fetchRecords(1, 500, TimeUnit.MILLISECONDS);
-        delta = System.currentTimeMillis() - startMills;
-        assertTrue(delta >= 500 && delta < 650, "Delta is not in [500,650) : " 
+ delta);
+        delta = System.currentTimeMillis() - startMillis;
+        assertTrue(delta >= 500 && delta < 750, "Delta is not in [500,750) : " 
+ delta);
     }
 }