fixtypo_texy_to_text (#1754)

DataLinkDC · Mar 22, 2023 · 63ea7d9 · 63ea7d9
1 parent d8964f7
commit 63ea7d9
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 6 deletions.
diff --git a/dinky-metadata/dinky-metadata-doris/src/main/java/org/dinky/metadata/driver/DorisDriver.java b/dinky-metadata/dinky-metadata-doris/src/main/java/org/dinky/metadata/driver/DorisDriver.java
@@ -121,7 +121,7 @@ public Map<String, String> getFlinkColumnTypeConversion() {
         map.put("SMALLINT", "SMALLINT");
         map.put("INT", "INT");
         map.put("VARCHAR", "STRING");
-        map.put("TEXY", "STRING");
+        map.put("TEXT", "STRING");
         map.put("DATETIME", "TIMESTAMP");
         return map;
     }

diff --git a/dinky-metadata/dinky-metadata-hive/src/main/java/org/dinky/metadata/driver/HiveDriver.java b/dinky-metadata/dinky-metadata-hive/src/main/java/org/dinky/metadata/driver/HiveDriver.java
@@ -312,8 +312,7 @@ public Map<String, String> getFlinkColumnTypeConversion() {
         map.put("SMALLINT", "SMALLINT");
         map.put("INT", "INT");
         map.put("VARCHAR", "STRING");
-        map.put("TEXY", "STRING");
-        map.put("INT", "INT");
+        map.put("TEXT", "STRING");
         map.put("DATETIME", "TIMESTAMP");
         return map;
     }

diff --git a/...-metadata/dinky-metadata-presto/src/main/java/org/dinky/metadata/driver/PrestoDriver.java b/...-metadata/dinky-metadata-presto/src/main/java/org/dinky/metadata/driver/PrestoDriver.java
@@ -354,8 +354,7 @@ public Map<String, String> getFlinkColumnTypeConversion() {
         map.put("SMALLINT", "SMALLINT");
         map.put("INT", "INT");
         map.put("VARCHAR", "STRING");
-        map.put("TEXY", "STRING");
-        map.put("INT", "INT");
+        map.put("TEXT", "STRING");
         map.put("DATETIME", "TIMESTAMP");
         return map;
     }

diff --git a/...ata/dinky-metadata-starrocks/src/main/java/org/dinky/metadata/driver/StarRocksDriver.java b/...ata/dinky-metadata-starrocks/src/main/java/org/dinky/metadata/driver/StarRocksDriver.java
@@ -105,7 +105,7 @@ public Map<String, String> getFlinkColumnTypeConversion() {
         map.put("SMALLINT", "SMALLINT");
         map.put("INT", "INT");
         map.put("VARCHAR", "STRING");
-        map.put("TEXY", "STRING");
+        map.put("TEXT", "STRING");
         map.put("DATETIME", "TIMESTAMP");
         return map;
     }