[chunjun-core] bug fix for local mode.

DTStack · Feb 20, 2024 · b502cfb · b502cfb
1 parent 4b610c9
commit b502cfb
Showing 1 changed file with 1 addition and 28 deletions.
diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/util/ConnectorNameConvertUtil.java b/chunjun-core/src/main/java/com/dtstack/chunjun/util/ConnectorNameConvertUtil.java
@@ -37,38 +37,11 @@ public class ConnectorNameConvertUtil {
         connectorNameMap.put("restapi", new Tuple3<>("http", "http", "http"));
         connectorNameMap.put(
                 "adbpostgresql", new Tuple3<>("postgresql", "postgresql", "postgresql"));
-        connectorNameMap.put("metadatamysql", new Tuple3<>("mysql", "metaDataMysql", "mysql"));
-        connectorNameMap.put("metadatakafka", new Tuple3<>("kafka", "metaDataKafka", "kafka"));
-        connectorNameMap.put(
-                "metadatavertica", new Tuple3<>("vertica", "metaDataVertica", "vertica"));
-        connectorNameMap.put(
-                "metadatahbase", new Tuple3<>("hbase14", "metaDataHBase14", "hbase14"));
-        connectorNameMap.put("metadatahive2", new Tuple3<>("hive", "metaDataHive", "hive"));
-        connectorNameMap.put("metadatahive1", new Tuple3<>("hive1", "metaDataHive1", "hive1"));
-        connectorNameMap.put(
-                "metadatasparkthrift",
-                new Tuple3<>("sparkthrift", "metaDataSparkThrift", "sparkthrift"));
-        connectorNameMap.put(
-                "metadatasqlserver", new Tuple3<>("sqlserver", "metaDataSqlServer", "sqlserver"));
-        connectorNameMap.put("metadataoracle", new Tuple3<>("oracle", "metaDataOracle", "oracle"));
-        connectorNameMap.put(
-                "metadataphoenix5", new Tuple3<>("phoenix5", "metaDataPhoenix5", "phoenix5"));
-        connectorNameMap.put("metadatahive1cdc", new Tuple3<>("hive", "metaDataHiveCdc", "hive"));
-        connectorNameMap.put("metadatahive2cdc", new Tuple3<>("hive", "metaDataHiveCdc", "hive"));
-        connectorNameMap.put(
-                "metadatasparkthriftcdc", new Tuple3<>("hive", "metaDataHiveCdc", "hive"));
-        connectorNameMap.put("metadatatidb", new Tuple3<>("tidb", "metaDataTidb", "tidb"));
+
         connectorNameMap.put("dorisbatch", new Tuple3<>("doris", "doris", "doris"));
         connectorNameMap.put("starrocks", new Tuple3<>("starrocks", "starRocks", null));
         connectorNameMap.put("gbase", new Tuple3<>("gbase", "gBase", null));
         connectorNameMap.put("protobuf", new Tuple3<>("pbformat", "pbformat", null));
-        connectorNameMap.put("huaweihbase", new Tuple3<>("huaweihbase", "huaweiHbase", null));
-        connectorNameMap.put("huaweihdfs", new Tuple3<>("huaweihdfs", "huaweiHdfs", null));
-        connectorNameMap.put("pgwal", new Tuple3<>("pgwal", "PGWal", null));
-        connectorNameMap.put("kafka-hw", new Tuple3<>("huaweikafka", "huaweikafka", null));
-        connectorNameMap.put("hudi", new Tuple3<>("hudi", "hoodie", null));
-        connectorNameMap.put(
-                "inceptorhyperbase", new Tuple3<>("inceptorhyperbase", "DirectHyperbase", null));
     }
 
     public static String convertClassPrefix(String originName) {