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

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


The following commit(s) were added to refs/heads/master by this push:
     new 856716742 [INLONG-7349][SDK] Fix init failure when a single SortTask 
create multiple SortClients (#7350)
856716742 is described below

commit 856716742034bd16869cfc0d7396a24d09f3d759
Author: vernedeng <[email protected]>
AuthorDate: Sat Feb 11 22:46:03 2023 +0800

    [INLONG-7349][SDK] Fix init failure when a single SortTask create multiple 
SortClients (#7350)
---
 .../src/main/java/org/apache/inlong/sdk/sort/api/ClientContext.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ClientContext.java
 
b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ClientContext.java
index fb600cfcc..4420fcfc7 100644
--- 
a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ClientContext.java
+++ 
b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ClientContext.java
@@ -22,6 +22,7 @@ import org.apache.inlong.sdk.sort.entity.InLongTopic;
 import org.apache.inlong.sdk.sort.metrics.SortSdkMetricItem;
 import org.apache.inlong.sdk.sort.metrics.SortSdkMetricItemSet;
 
+import java.security.SecureRandom;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -36,7 +37,7 @@ public abstract class ClientContext implements Cleanable {
     public ClientContext(SortClientConfig config) {
         this.config = config;
         this.sortTaskId = config.getSortTaskId();
-        this.metricItemSet = new SortSdkMetricItemSet(config.getSortTaskId());
+        this.metricItemSet = new SortSdkMetricItemSet(config.getSortTaskId() + 
new SecureRandom().nextInt());
         MetricRegister.register(this.metricItemSet);
     }
 

Reply via email to