[incubator-paimon] branch master updated: [cdc] Compute column function should be case-insensitive (#2015)

[lzljs3620320]

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

lzljs3620320 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 025c8b001 [cdc] Compute column function should be case-insensitive 
(#2015)
025c8b001 is described below

commit 025c8b001a313d6a367af815230754d91ebd1c87
Author: Jingsong Lee <jingsongl...@gmail.com>
AuthorDate: Thu Sep 14 18:17:30 2023 +0800

    [cdc] Compute column function should be case-insensitive (#2015)
---
 .../src/main/java/org/apache/paimon/flink/action/cdc/Expression.java    | 2 +-
 .../paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java       | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java
 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java
index 15e9c683f..0f6647f94 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java
@@ -51,7 +51,7 @@ public interface Expression extends Serializable {
 
     static Expression create(
             String exprName, String fieldReference, DataType fieldType, 
String... literals) {
-        switch (exprName) {
+        switch (exprName.toLowerCase()) {
             case "year":
                 return year(fieldReference);
             case "month":
diff --git 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java
 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java
index 88133d222..4b3c6ef13 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionITCase.java
@@ -716,7 +716,7 @@ public class MySqlSyncTableActionITCase extends 
MySqlActionITCaseBase {
                         
"_date_format_timestamp=date_format(_timestamp,yyyyMMdd)",
                         "_substring_date1=substring(_date,2)",
                         "_substring_date2=substring(_timestamp,5,10)",
-                        "_truncate_date=truncate(pk,2)");
+                        "_truncate_date=trUNcate(pk,2)"); // test 
case-insensitive too
 
         MySqlSyncTableAction action =
                 syncTableActionBuilder(mySqlConfig)