[inlong] branch master updated: [INLONG-9084][Sort] Fix failure of parsing InlongGroupId when report Inlong Audit (#9085)

[zirui]

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

zirui 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 de653f34ae [INLONG-9084][Sort] Fix failure of parsing InlongGroupId 
when report Inlong Audit (#9085)
de653f34ae is described below

commit de653f34ae959ad4451186b8946ddc5cf107b9c0
Author: vernedeng <verned...@apache.org>
AuthorDate: Fri Oct 20 17:29:00 2023 +0800

    [INLONG-9084][Sort] Fix failure of parsing InlongGroupId when report Inlong 
Audit (#9085)
---
 .../java/org/apache/inlong/sort/standalone/metrics/SortMetricItem.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/metrics/SortMetricItem.java
 
b/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/metrics/SortMetricItem.java
index b9c5721383..0daf242f77 100644
--- 
a/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/metrics/SortMetricItem.java
+++ 
b/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/metrics/SortMetricItem.java
@@ -157,7 +157,7 @@ public class SortMetricItem extends MetricItem {
     public static String getInlongGroupId(Map<String, String> headers) {
         String inlongGroupId = headers.get(Constants.INLONG_GROUP_ID);
         if (inlongGroupId == null) {
-            inlongGroupId = headers.getOrDefault(Constants.TOPIC, "");
+            inlongGroupId = headers.getOrDefault(AttributeConstants.GROUP_ID, 
"");
         }
         return inlongGroupId;
     }