[incubator-paimon] branch master updated: [cdc] fix mysql cdc test char to string type mapping (#2066)

[kerwin]

This is an automated email from the ASF dual-hosted git repository.

kerwin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 9e07a3d4b [cdc] fix mysql cdc test char to string type mapping (#2066)
9e07a3d4b is described below

commit 9e07a3d4b665bca0d041531f3bf109d5bf4f0a0f
Author: Kerwin <37063904+zhuangch...@users.noreply.github.com>
AuthorDate: Mon Sep 25 09:23:17 2023 +0800

    [cdc] fix mysql cdc test char to string type mapping (#2066)
---
 .../paimon/flink/action/cdc/mysql/MySqlCdcTypeMappingITCase.java  | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlCdcTypeMappingITCase.java
 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlCdcTypeMappingITCase.java
index e1b77d293..51e78afb2 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlCdcTypeMappingITCase.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlCdcTypeMappingITCase.java
@@ -458,7 +458,9 @@ public class MySqlCdcTypeMappingITCase extends 
MySqlActionITCaseBase {
             // test schema evolution
             RowType rowType =
                     RowType.of(
-                            new DataType[] {DataTypes.INT().notNull(), 
DataTypes.STRING()},
+                            new DataType[] {
+                                DataTypes.INT().notNull(), 
DataTypes.STRING().notNull()
+                            },
                             new String[] {"pk", "v1"});
             waitForResult(
                     Collections.singletonList("+I[1, 1]"),
@@ -472,7 +474,9 @@ public class MySqlCdcTypeMappingITCase extends 
MySqlActionITCaseBase {
             rowType =
                     RowType.of(
                             new DataType[] {
-                                DataTypes.INT().notNull(), DataTypes.STRING(), 
DataTypes.STRING()
+                                DataTypes.INT().notNull(),
+                                DataTypes.STRING().notNull(),
+                                DataTypes.STRING()
                             },
                             new String[] {"pk", "v1", "v2"});
             waitForResult(