Skip to content

D
dlink
Unverified Commit 486174b1 authored by aiwenmo's avatar aiwenmo Committed by GitHub
Browse files
Options

[fix][metadata] MySqlDriver Flink Column Type Conversion error 

fix(metadata):  MySqlDriver Flink Column Type Conversion error
parents 59dd7adc 4c47f2b9
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
dlink-metadata/dlink-metadata-mysql/src/main/java/com/dlink/metadata/driver/MySqlDriver.java
View file @ 486174b1
...@@ -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