[INLONG-10152][Sort] fix defect.

apache · May 9, 2024 · 93b09dd · 93b09dd
1 parent 7dc2d8c
commit 93b09dd
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 9 deletions.
diff --git a/...g-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/MetricOption.java b/...g-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/MetricOption.java
@@ -83,12 +83,8 @@ private MetricOption(
     public Map<String, String> getLabels() {
         return labels;
     }
-
-    public Set<String> getIpPortSet() {
-        return ipPortSet;
-    }
-
-    public HashSet<String> getIpPortSetAsHashSet() {
+
+    public HashSet<String> getIpPortSet() {
         return new HashSet<>(ipPortSet);
     }
 

diff --git a/...sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SinkMetricData.java b/...sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SinkMetricData.java
@@ -101,7 +101,7 @@ public SinkMetricData(MetricOption option, MetricGroup metricGroup) {
         }
 
         if (option.getIpPorts().isPresent()) {
-            AuditOperator.getInstance().setAuditProxy(option.getIpPortSetAsHashSet());
+            AuditOperator.getInstance().setAuditProxy(option.getIpPortSet());
             this.auditOperator = AuditOperator.getInstance();
             this.auditKeys = option.getInlongAuditKeys();
         }

diff --git a/...rt/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SourceMetricData.java b/...rt/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SourceMetricData.java
@@ -104,7 +104,7 @@ public SourceMetricData(MetricOption option, MetricGroup metricGroup) {
         }
 
         if (option.getIpPorts().isPresent()) {
-            AuditOperator.getInstance().setAuditProxy(option.getIpPortSetAsHashSet());
+            AuditOperator.getInstance().setAuditProxy(option.getIpPortSet());
             this.auditOperator = AuditOperator.getInstance();
             this.auditKeys = option.getInlongAuditKeys();
         }
@@ -114,7 +114,7 @@ public SourceMetricData(MetricOption option) {
         this.labels = option.getLabels();
 
         if (option.getIpPorts().isPresent()) {
-            AuditOperator.getInstance().setAuditProxy(option.getIpPortSetAsHashSet());
+            AuditOperator.getInstance().setAuditProxy(option.getIpPortSet());
             this.auditOperator = AuditOperator.getInstance();
             this.auditKeys = option.getInlongAuditKeys();
         }