(shardingsphere) branch master updated: Rename CDCClientConfiguration.timeoutMillis (#35072)

[zhangliang]

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

zhangliang 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 1cc000d0bd4 Rename CDCClientConfiguration.timeoutMillis (#35072)
1cc000d0bd4 is described below

commit 1cc000d0bd436d7dd8418ccf06b3ae1e3000976c
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Mon Mar 24 18:48:14 2025 +0800

    Rename CDCClientConfiguration.timeoutMillis (#35072)
---
 .../shardingsphere/data/pipeline/cdc/client/CDCClient.java     | 10 +++++-----
 .../pipeline/cdc/client/config/CDCClientConfiguration.java     |  2 +-
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java
 
b/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java
index e1b31c2decc..163a4de8fc2 100644
--- 
a/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java
+++ 
b/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java
@@ -139,7 +139,7 @@ public final class CDCClient implements AutoCloseable {
         ResponseFuture responseFuture = new ResponseFuture(requestId, 
Type.LOGIN);
         connectionContext.getResponseFutureMap().put(requestId, 
responseFuture);
         channel.writeAndFlush(data);
-        responseFuture.waitResponseResult(config.getTimeoutMills(), 
connectionContext);
+        responseFuture.waitResponseResult(config.getTimeoutMillis(), 
connectionContext);
         log.info("Login success, username: {}", parameter.getUsername());
     }
     
@@ -164,7 +164,7 @@ public final class CDCClient implements AutoCloseable {
         ResponseFuture responseFuture = new ResponseFuture(requestId, 
Type.STREAM_DATA);
         connectionContext.getResponseFutureMap().put(requestId, 
responseFuture);
         channel.writeAndFlush(request);
-        String result = 
responseFuture.waitResponseResult(config.getTimeoutMills(), 
connectionContext).toString();
+        String result = 
responseFuture.waitResponseResult(config.getTimeoutMillis(), 
connectionContext).toString();
         log.info("Start streaming success, streaming id: {}", result);
         return result;
     }
@@ -182,7 +182,7 @@ public final class CDCClient implements AutoCloseable {
         ClientConnectionContext connectionContext = 
channel.attr(ClientConnectionContext.CONTEXT_KEY).get();
         connectionContext.getResponseFutureMap().put(requestId, 
responseFuture);
         channel.writeAndFlush(request);
-        responseFuture.waitResponseResult(config.getTimeoutMills(), 
connectionContext);
+        responseFuture.waitResponseResult(config.getTimeoutMillis(), 
connectionContext);
         log.info("Restart streaming success, streaming id: {}", streamingId);
     }
     
@@ -199,7 +199,7 @@ public final class CDCClient implements AutoCloseable {
         ClientConnectionContext connectionContext = 
channel.attr(ClientConnectionContext.CONTEXT_KEY).get();
         connectionContext.getResponseFutureMap().put(requestId, 
responseFuture);
         channel.writeAndFlush(request);
-        responseFuture.waitResponseResult(config.getTimeoutMills(), 
connectionContext);
+        responseFuture.waitResponseResult(config.getTimeoutMillis(), 
connectionContext);
         connectionContext.getStreamingIds().remove(streamingId);
         log.info("Stop streaming success, streaming id: {}", streamingId);
     }
@@ -217,7 +217,7 @@ public final class CDCClient implements AutoCloseable {
         ClientConnectionContext connectionContext = 
channel.attr(ClientConnectionContext.CONTEXT_KEY).get();
         connectionContext.getResponseFutureMap().put(requestId, 
responseFuture);
         channel.writeAndFlush(request);
-        responseFuture.waitResponseResult(config.getTimeoutMills(), 
connectionContext);
+        responseFuture.waitResponseResult(config.getTimeoutMillis(), 
connectionContext);
         connectionContext.getStreamingIds().remove(streamingId);
         log.info("Drop streaming success, streaming id: {}", streamingId);
     }
diff --git 
a/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/config/CDCClientConfiguration.java
 
b/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/config/CDCClientConfiguration.java
index 6b2b5a39002..443dbc68794 100644
--- 
a/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/config/CDCClientConfiguration.java
+++ 
b/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/config/CDCClientConfiguration.java
@@ -31,5 +31,5 @@ public final class CDCClientConfiguration {
     
     private final int port;
     
-    private final int timeoutMills;
+    private final int timeoutMillis;
 }