[inlong] branch master updated: [INLONG-7035][SDK] Fix the id generator not globally unique for DataProxy (#7036)

[healchow]

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 259ba57dc [INLONG-7035][SDK] Fix the id generator not globally unique 
for DataProxy (#7036)
259ba57dc is described below

commit 259ba57dcc0e836dc13ad3328a4b2383bd9dc615
Author: woofyzhao <490467...@qq.com>
AuthorDate: Fri Dec 23 16:34:05 2022 +0800

    [INLONG-7035][SDK] Fix the id generator not globally unique for DataProxy 
(#7036)
---
 .../java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java
 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java
index 4cf0144c2..05b41ee45 100644
--- 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java
+++ 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/DefaultMessageSender.java
@@ -48,8 +48,8 @@ public class DefaultMessageSender implements MessageSender {
             new ConcurrentHashMap<>();
     private static final AtomicBoolean MANAGER_FETCHER_THREAD_STARTED = new 
AtomicBoolean(false);
     private static ManagerFetcherThread managerFetcherThread;
+    private static final SequentialID idGenerator = new 
SequentialID(Utils.getLocalIp());
     private final Sender sender;
-    private final SequentialID idGenerator;
     private final IndexCollectThread indexCol;
     /* Store index <groupId_streamId,cnt> */
     private final Map<String, Long> storeIndex = new ConcurrentHashMap<String, 
Long>();
@@ -68,7 +68,6 @@ public class DefaultMessageSender implements MessageSender {
     public DefaultMessageSender(ProxyClientConfig configure, ThreadFactory 
selfDefineFactory) throws Exception {
         ProxyUtils.validClientConfig(configure);
         sender = new Sender(configure, selfDefineFactory);
-        idGenerator = new SequentialID(Utils.getLocalIp());
         groupId = configure.getGroupId();
         indexCol = new IndexCollectThread(storeIndex);
         indexCol.start();