Commit 4c47f2b9 authored by huangxp's avatar huangxp

fix(metadata): MySqlDriver Flink Column Type Conversion error

parent 59dd7adc
...@@ -45,7 +45,7 @@ public class MySqlDriver extends AbstractJdbcDriver { ...@@ -45,7 +45,7 @@ public class MySqlDriver extends AbstractJdbcDriver {
public Map<String, String> getFlinkColumnTypeConversion() { public Map<String, String> getFlinkColumnTypeConversion() {
HashMap<String, String> map = new HashMap<>(); HashMap<String, String> map = new HashMap<>();
map.put("VARCHAR", "STRING"); map.put("VARCHAR", "STRING");
map.put("TEXY", "STRING"); map.put("TEXT", "STRING");
map.put("INT", "INT"); map.put("INT", "INT");
map.put("DATETIME", "TIMESTAMP"); map.put("DATETIME", "TIMESTAMP");
return map; return map;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment