vinlee19 commented on code in PR #431:
URL:
https://github.com/apache/doris-flink-connector/pull/431#discussion_r1682413794
##########
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java:
##########
@@ -92,10 +92,22 @@ public class MysqlType {
private static final String JSON = "JSON";
private static final String ENUM = "ENUM";
private static final String SET = "SET";
+ private static final String GEOMETRY = "GEOMETRY";
+ private static final String POINT = "POINT";
+ private static final String LINESTRING = "LINESTRING";
+ private static final String POLYGON = "POLYGON";
+ private static final String MULTIPOINT = "MULTIPOINT";
+ private static final String MULTILINESTRING = "MULTILINESTRING";
+ private static final String MULTIPOLYGON = "MULTIPOLYGON";
+ private static final String GEOMETRYCOLLECTION = "GEOMETRYCOLLECTION";
public static String toDorisType(String type, Integer length, Integer
scale) {
switch (type.toUpperCase()) {
case BIT:
+ if (length > 1) {
+ return DorisType.STRING;
+ }
+ return DorisType.BOOLEAN;
Review Comment:
when the length of bit is greater than 1,it will convert to a string.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
