This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 65e1a14 [fix] extend varchar column length in table auto created by
script (#160)
65e1a14 is described below
commit 65e1a1485d19a3624278bd62f17c97fc2c232c91
Author: zhxiaofan <[email protected]>
AuthorDate: Mon Nov 20 11:40:17 2023 +0800
[fix] extend varchar column length in table auto created by script (#160)
---
.../main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java | 2 +-
.../doris/flink/sink/writer/TestJsonDebeziumSchemaSerializer.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java
index 143ea52..1b0b9d4 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java
@@ -142,7 +142,7 @@ public class MysqlType {
case CHAR:
case VARCHAR:
Preconditions.checkNotNull(length);
- return length * 3 > 65533 ? DorisType.STRING :
String.format("%s(%s)", DorisType.VARCHAR, length * 3);
+ return length * 4 > 65533 ? DorisType.STRING :
String.format("%s(%s)", DorisType.VARCHAR, length * 4);
case TINYTEXT:
case TEXT:
case MEDIUMTEXT:
diff --git
a/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestJsonDebeziumSchemaSerializer.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestJsonDebeziumSchemaSerializer.java
index 59bfe44..11cac1c 100644
---
a/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestJsonDebeziumSchemaSerializer.java
+++
b/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/TestJsonDebeziumSchemaSerializer.java
@@ -163,7 +163,7 @@ public class TestJsonDebeziumSchemaSerializer {
@Test
public void testExtractDDLListMultipleColumns() throws IOException {
String sql0 = "ALTER TABLE test.t1 ADD COLUMN c2 INT";
- String sql1 = "ALTER TABLE test.t1 ADD COLUMN c555 VARCHAR(300)";
+ String sql1 = "ALTER TABLE test.t1 ADD COLUMN c555 VARCHAR(400)";
String sql2 = "ALTER TABLE test.t1 ADD COLUMN c666 INT DEFAULT '100'";
String sql3 = "ALTER TABLE test.t1 ADD COLUMN c4 BIGINT DEFAULT '555'";
String sql4 = "ALTER TABLE test.t1 ADD COLUMN c199 INT";
@@ -243,7 +243,7 @@ public class TestJsonDebeziumSchemaSerializer {
public void testFillOriginSchema() throws IOException {
Map<String, FieldSchema> srcFiledSchemaMap = new LinkedHashMap<>();
srcFiledSchemaMap.put("id", new FieldSchema("id", "INT", null, null));
- srcFiledSchemaMap.put("name", new FieldSchema("name", "VARCHAR(150)",
null, null));
+ srcFiledSchemaMap.put("name", new FieldSchema("name", "VARCHAR(200)",
null, null));
srcFiledSchemaMap.put("test_time", new FieldSchema("test_time",
"DATETIMEV2(0)", null, null));
srcFiledSchemaMap.put("c1", new FieldSchema("c1", "INT", "'100'",
null));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
