(shenyu) branch master updated: [type: bug] Fix TimeUnit.MICROSECONDS to MILLISECONDS in log collect clients (#6885) (#6996)

[liuhongyu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 6e9880d7b1 [type: bug] Fix TimeUnit.MICROSECONDS to MILLISECONDS in 
log collect clients (#6885) (#6996)
6e9880d7b1 is described below

commit 6e9880d7b1d821177ad07f0e290e2c3cac380d30
Author: Arvin <31638790+zhang-ar...@users.noreply.github.com>
AuthorDate: Thu Sep 3 19:39:10 2026 +0800

    [type: bug] Fix TimeUnit.MICROSECONDS to MILLISECONDS in log collect 
clients (#6885) (#6996)
    
    Signed-off-by: zhang-arvin <arvin.zh...@htx-inc.com>
    Co-authored-by: aias00 <liuhon...@apache.org>
---
 .../shenyu/plugin/aliyun/sls/client/AliyunSlsLogCollectClient.java      | 2 +-
 .../shenyu/plugin/huawei/lts/client/HuaweiLtsLogCollectClient.java      | 2 +-
 .../shenyu/plugin/tencent/cls/client/TencentClsLogCollectClient.java    | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-aliyun-sls/src/main/java/org/apache/shenyu/plugin/aliyun/sls/client/AliyunSlsLogCollectClient.java
 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-aliyun-sls/src/main/java/org/apache/shenyu/plugin/aliyun/sls/client/AliyunSlsLogCollectClient.java
index 412b509e66..0ca5b6da85 100644
--- 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-aliyun-sls/src/main/java/org/apache/shenyu/plugin/aliyun/sls/client/AliyunSlsLogCollectClient.java
+++ 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-aliyun-sls/src/main/java/org/apache/shenyu/plugin/aliyun/sls/client/AliyunSlsLogCollectClient.java
@@ -189,7 +189,7 @@ public class AliyunSlsLogCollectClient extends 
AbstractLogConsumeClient<AliyunLo
             LOG.warn("send thread count number too large!");
             sendThreadCount = GenericLoggingConstant.MAX_ALLOW_THREADS;
         }
-        return new ThreadPoolExecutor(sendThreadCount, 
GenericLoggingConstant.MAX_ALLOW_THREADS, 60000L, TimeUnit.MICROSECONDS,
+        return new ThreadPoolExecutor(sendThreadCount, 
GenericLoggingConstant.MAX_ALLOW_THREADS, 60000L, TimeUnit.MILLISECONDS,
                 new 
LinkedBlockingQueue<>(GenericLoggingConstant.MAX_QUEUE_NUMBER), 
ShenyuThreadFactory.create("shenyu-aliyun-sls", true),
                 new ThreadPoolExecutor.AbortPolicy());
     }
diff --git 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-huawei-lts/src/main/java/org/apache/shenyu/plugin/huawei/lts/client/HuaweiLtsLogCollectClient.java
 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-huawei-lts/src/main/java/org/apache/shenyu/plugin/huawei/lts/client/HuaweiLtsLogCollectClient.java
index 05e1656777..8e13ec31ff 100644
--- 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-huawei-lts/src/main/java/org/apache/shenyu/plugin/huawei/lts/client/HuaweiLtsLogCollectClient.java
+++ 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-huawei-lts/src/main/java/org/apache/shenyu/plugin/huawei/lts/client/HuaweiLtsLogCollectClient.java
@@ -175,7 +175,7 @@ public class HuaweiLtsLogCollectClient extends 
AbstractLogConsumeClient<HuaweiLo
             LOG.warn("send thread count number too large!");
             threadCount = GenericLoggingConstant.MAX_ALLOW_THREADS;
         }
-        return new ThreadPoolExecutor(threadCount, 
GenericLoggingConstant.MAX_ALLOW_THREADS, 60000L, TimeUnit.MICROSECONDS,
+        return new ThreadPoolExecutor(threadCount, 
GenericLoggingConstant.MAX_ALLOW_THREADS, 60000L, TimeUnit.MILLISECONDS,
                 new 
LinkedBlockingQueue<>(GenericLoggingConstant.MAX_QUEUE_NUMBER), 
ShenyuThreadFactory.create("shenyu-huawei-lts", true),
                 new ThreadPoolExecutor.AbortPolicy());
     }
diff --git 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-tencent-cls/src/main/java/org/apache/shenyu/plugin/tencent/cls/client/TencentClsLogCollectClient.java
 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-tencent-cls/src/main/java/org/apache/shenyu/plugin/tencent/cls/client/TencentClsLogCollectClient.java
index d4d071c2b0..4b90205033 100644
--- 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-tencent-cls/src/main/java/org/apache/shenyu/plugin/tencent/cls/client/TencentClsLogCollectClient.java
+++ 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-tencent-cls/src/main/java/org/apache/shenyu/plugin/tencent/cls/client/TencentClsLogCollectClient.java
@@ -168,7 +168,7 @@ public class TencentClsLogCollectClient extends 
AbstractLogConsumeClient<Tencent
             LOG.warn("send thread count number too large!");
             threadCount = GenericLoggingConstant.MAX_ALLOW_THREADS;
         }
-        return new ThreadPoolExecutor(threadCount, 
GenericLoggingConstant.MAX_ALLOW_THREADS, 60000L, TimeUnit.MICROSECONDS,
+        return new ThreadPoolExecutor(threadCount, 
GenericLoggingConstant.MAX_ALLOW_THREADS, 60000L, TimeUnit.MILLISECONDS,
                 new 
LinkedBlockingQueue<>(GenericLoggingConstant.MAX_QUEUE_NUMBER), 
ShenyuThreadFactory.create("shenyu-tencent-cls", true),
                 new ThreadPoolExecutor.AbortPolicy());
     }