[INLONG-11352][SDK] Delete useless enumeration

justinwwhuang · Oct 16, 2024 · cf9cef4 · cf9cef4
1 parent e9dba7c
commit cf9cef4
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 49 deletions.
diff --git a/...sdk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/PatternReplaceUtils.java b/...sdk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/PatternReplaceUtils.java
@@ -31,7 +31,7 @@ public final class PatternReplaceUtils {
 
     public static String replace(String pattern, Map<String, String> params) {
         if (pattern == null) {
-            return pattern;
+            return null;
         }
         Matcher matcher = REGEX_PATTERN.matcher(pattern);
         StringBuffer sb = new StringBuffer();

diff --git a/...y-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/SchemaUpdateExceptionPolicy.java b/...y-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/SchemaUpdateExceptionPolicy.java
diff --git a/...dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/sink/InlongSdkDirtySink.java b/...dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/sink/InlongSdkDirtySink.java
@@ -94,7 +94,7 @@ public void invoke(DirtyData dirtyData) {
 
     private InlongSdkOptions getOptions(Configure config) {
         return InlongSdkOptions.builder()
-                .inlongManagerAddr(config.get(DIRTY_SIDE_OUTPUT_INLONG_MANAGER))
+                .inlongManagerAddr(config.get(DIRTY_SIDE_OUTPUT_INLONG_MANAGER_ADDR))
                 .inlongGroupId(config.get(DIRTY_SIDE_OUTPUT_INLONG_GROUP))
                 .inlongStreamId(config.get(DIRTY_SIDE_OUTPUT_INLONG_STREAM))
                 .inlongManagerAuthKey(config.get(DIRTY_SIDE_OUTPUT_INLONG_AUTH_KEY))