fix ci failure.

aiwenmo · Jan 31, 2024 · c2f2540 · c2f2540
1 parent 2baab0f
commit c2f2540
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 8 deletions.
diff --git a/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/parser/JaninoParser.java b/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/parser/JaninoParser.java
@@ -41,12 +41,7 @@ public class JaninoParser {
 
     private static final List<SqlTypeName> SQL_TYPE_NAME_IGNORE = Arrays.asList(SqlTypeName.SYMBOL);
     private static final List<String> SQL_NAME_CALL_FUNCTION =
-            Arrays.asList(
-                    "LOCALTIME",
-                    "LOCALTIMESTAMP",
-                    "CURRENT_TIME",
-                    "CURRENT_DATE",
-                    "CURRENT_TIMESTAMP");
+            Arrays.asList("LOCALTIMESTAMP", "CURRENT_TIME", "CURRENT_DATE", "CURRENT_TIMESTAMP");
 
     public static String loadSystemFunction(String expression) {
         return "import static com.ververica.cdc.runtime.functions.SystemFunctionUtils.*;"

diff --git a/...untime/src/main/java/com/ververica/cdc/runtime/parser/validate/FlinkCDCOperatorTable.java b/...untime/src/main/java/com/ververica/cdc/runtime/parser/validate/FlinkCDCOperatorTable.java
@@ -189,7 +189,7 @@ public SqlSyntax getSyntax() {
                     .notDeterministic()
                     .build();
     public static final SqlFunction MOD = SqlStdOperatorTable.MOD;
-    public static final SqlFunction LOCALTIME = SqlStdOperatorTable.LOCALTIME;
+
     public static final SqlFunction YEAR = SqlStdOperatorTable.YEAR;
     public static final SqlFunction QUARTER = SqlStdOperatorTable.QUARTER;
     public static final SqlFunction MONTH = SqlStdOperatorTable.MONTH;

diff --git a/flink-cdc-runtime/src/test/java/com/ververica/cdc/runtime/parser/FlinkSqlParserTest.java b/flink-cdc-runtime/src/test/java/com/ververica/cdc/runtime/parser/FlinkSqlParserTest.java
@@ -219,7 +219,6 @@ public void testTranslateFilterToJaninoExpression() {
         testFilterExpression("floor(2)", "floor(2)");
         testFilterExpression("round(2,2)", "round(2, 2)");
         testFilterExpression("uuid()", "uuid()");
-        testFilterExpression("id = LOCALTIME", "id == localtime()");
         testFilterExpression("id = LOCALTIMESTAMP", "id == localtimestamp()");
         testFilterExpression("id = CURRENT_TIME", "id == currentTime()");
         testFilterExpression("id = CURRENT_DATE", "id == currentDate()");