fix

vernedeng · Jun 30, 2024 · de52c9b · de52c9b
1 parent d8fb950
commit de52c9b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...src/main/java/org/apache/inlong/sort/standalone/config/holder/CommonPropertiesHolder.java b/...src/main/java/org/apache/inlong/sort/standalone/config/holder/CommonPropertiesHolder.java
@@ -40,6 +40,7 @@ public class CommonPropertiesHolder {
     public static final String KEY_COMMON_PROPERTIES = "common_properties_loader";
     public static final String KEY_CLUSTER_ID = "clusterId";
     public static final String KEY_SORT_SOURCE_ACKPOLICY = "sortSource.ackPolicy";
+    public static final String KEY_USE_UNIFIED_CONFIGURATION = "useUnifiedConfiguration";
 
     private static Map<String, String> props;
     private static Context context;

diff --git a/...t-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/SinkContext.java b/...t-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/SinkContext.java
@@ -47,7 +47,6 @@ public class SinkContext {
     public static final String KEY_RELOADINTERVAL = "reloadInterval";
     public static final String KEY_TASK_NAME = "taskName";
     public static final String KEY_MAX_BUFFERQUEUE_SIZE_KB = "maxBufferQueueSizeKb";
-    public static final String KEY_USE_UNIFIED_CONFIGURATION = "useUnifiedConfiguration";
     public static final int DEFAULT_MAX_BUFFERQUEUE_SIZE_KB = 128 * 1024;
     protected final String clusterId;
     protected final String taskName;
@@ -74,7 +73,8 @@ public SinkContext(String sinkName, Context context, Channel channel) {
         this.processInterval = sinkContext.getInteger(KEY_PROCESSINTERVAL, 100);
         this.reloadInterval = sinkContext.getLong(KEY_RELOADINTERVAL, 60000L);
         this.metricItemSet = new SortMetricItemSet(sinkName);
-        this.unifiedConfiguration = sinkContext.getBoolean(KEY_USE_UNIFIED_CONFIGURATION, false);
+        this.unifiedConfiguration = sinkContext.getBoolean(CommonPropertiesHolder.KEY_USE_UNIFIED_CONFIGURATION,
+                false);
         MetricRegister.register(this.metricItemSet);
     }