delete unused method

apache · Jan 13, 2025 · eeb763a · eeb763a
1 parent 951aced
commit eeb763a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 10 deletions.
diff --git a/streampark-common/src/main/scala/org/apache/streampark/common/util/PropertiesUtils.scala b/streampark-common/src/main/scala/org/apache/streampark/common/util/PropertiesUtils.scala
@@ -101,12 +101,6 @@ object PropertiesUtils extends Logger {
     }
   }
 
-  def fromYamlTextToJava(text: String): java.util.Map[String, String] = {
-    val scalaMap = fromYamlText(text)
-    val javaMap: java.util.Map[String, String] = scalaMap.asJava
-    javaMap
-  }
-
   def fromHoconText(conf: String): Map[String, String] = {
     require(conf != null, s"[StreamPark] fromHoconText: Hocon content must not be null")
     try parseHoconByReader(new StringReader(conf))

diff --git a/...reampark-flink-cdcclient/src/main/java/org/apache/streampark/flink/cdc/cli/CDCClient.java b/...reampark-flink-cdcclient/src/main/java/org/apache/streampark/flink/cdc/cli/CDCClient.java
@@ -17,16 +17,18 @@
 
 package org.apache.streampark.flink.cdc.cli;
 
+import org.apache.streampark.common.conf.ConfigKeys;
+import org.apache.streampark.common.util.DeflaterUtils;
+import org.apache.streampark.common.util.PropertiesUtils;
+
 import org.apache.flink.api.java.utils.ParameterTool;
 import org.apache.flink.cdc.common.configuration.Configuration;
 import org.apache.flink.cdc.composer.PipelineExecution;
 import org.apache.flink.configuration.CoreOptions;
 import org.apache.flink.runtime.jobgraph.SavepointRestoreSettings;
 import org.apache.flink.util.StringUtils;
 import org.apache.flink.yarn.configuration.YarnConfigOptions;
-import org.apache.streampark.common.conf.ConfigKeys;
-import org.apache.streampark.common.util.DeflaterUtils;
-import org.apache.streampark.common.util.PropertiesUtils;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -51,7 +53,7 @@ public static void main(String[] args) throws Exception {
         if (StringUtils.isNullOrWhitespaceOnly(cdcYamlDecode)
             || StringUtils.isNullOrWhitespaceOnly(appNameDecode)
             || StringUtils.isNullOrWhitespaceOnly(flinkConfigDecode)) {
-            LOG.error("--flink.conf or --app.name or --sql as cdc yaml must not be null.");
+            LOG.error("--flink.conf or --app.name or `cdc yaml` must not be null.");
             return;
         }