[inlong] branch master updated: [INLONG-7098][Common] Add UUID in MonitorIndex (#7099)

[dockerzhang]

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

dockerzhang 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 a6dd566be [INLONG-7098][Common] Add UUID in MonitorIndex (#7099)
a6dd566be is described below

commit a6dd566bef05819a525ab5313aff8f0e3bfffba5
Author: Goson Zhang <4675...@qq.com>
AuthorDate: Sat Dec 31 22:57:28 2022 +0800

    [INLONG-7098][Common] Add UUID in MonitorIndex (#7099)
---
 .../java/org/apache/inlong/common/monitor/MonitorIndex.java  | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/inlong-common/src/main/java/org/apache/inlong/common/monitor/MonitorIndex.java
 
b/inlong-common/src/main/java/org/apache/inlong/common/monitor/MonitorIndex.java
index 29ed10f42..caa18762b 100644
--- 
a/inlong-common/src/main/java/org/apache/inlong/common/monitor/MonitorIndex.java
+++ 
b/inlong-common/src/main/java/org/apache/inlong/common/monitor/MonitorIndex.java
@@ -20,6 +20,8 @@ package org.apache.inlong.common.monitor;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicLong;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -27,6 +29,7 @@ public class MonitorIndex {
 
     private static final Logger logger = 
LoggerFactory.getLogger(MonitorIndex.class);
     private static final LogCounter logPrinter = new LogCounter(10, 100000, 60 
* 1000);
+    private static final AtomicLong recId = new AtomicLong(0);
 
     private IndexCollectThread indexCol;
     private String name;
@@ -113,6 +116,8 @@ public class MonitorIndex {
 
         @Override
         public void run() {
+            String uuidStr;
+            long currentKey;
             Map<String, String> counterExt = new HashMap<String, String>();
             while (!bShutDown) {
                 try {
@@ -123,9 +128,12 @@ public class MonitorIndex {
                             return null;
                         });
                     }
+                    // get print time (second)
+                    currentKey = System.currentTimeMillis() / 1000;
                     for (Map.Entry<String, String> entrys : 
counterExt.entrySet()) {
-                        logger.info("{}#{}#{}",
-                                new Object[]{name, entrys.getKey(), 
entrys.getValue()});
+                        uuidStr = currentKey + "_" + recId.incrementAndGet();
+                        logger.info("{}#{}#{}#{}",
+                                new Object[]{name, uuidStr, entrys.getKey(), 
entrys.getValue()});
                     }
                     counterExt.clear();
                 } catch (Exception e) {