update

Author: Hisoka-X

flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java

@@ -2737,12 +2737,12 @@ void testTransformErrorMessage() {
                 .cause()
                 .isExactlyInstanceOf(FlinkRuntimeException.class)
                 .hasMessage(
-                        "Failed to compile expression TransformExpressionKey{expression='"
+                        "Failed to compile expression TransformExpressionKey{originalExpression='id1 > 0', expression='"
                                 + JaninoCompiler.LOAD_MODULES_EXPRESSION
                                 + "greaterThan($0, 0)', argumentNames=[__time_zone__, __epoch_time__], argumentClasses=[class java.lang.String, class java.lang.Long], returnClass=class java.lang.Boolean, columnNameMap={id1=$0}}")
                 .cause()
                 .hasMessageContaining(
-                        "Expression: "
+                        "Compiled expression: "
                                 + JaninoCompiler.LOAD_MODULES_EXPRESSION
                                 + "greaterThan($0, 0)")
                 .hasMessageContaining("Column name map: {$0 -> id1}")

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorTest.java

@@ -2767,13 +2767,12 @@ void testCastErrorTransform() throws Exception {
                                 + "\tcolumns={`col1` STRING NOT NULL,`castInt` INT,`castBoolean` BOOLEAN,`castTinyint` TINYINT,`castSmallint` SMALLINT,`castBigint` BIGINT,`castFloat` FLOAT,`castDouble` DOUBLE,`castChar` STRING,`castVarchar` STRING,`castDecimal` DECIMAL(4, 2),`castTimestamp` TIMESTAMP(3)}, primaryKeys=col1, options=().")
                 .cause()
                 .hasRootCauseInstanceOf(IllegalArgumentException.class)
-                .hasRootCauseMessage("Unable to parse given string as timestamp: 1.0");
-                .hasRootCauseInstanceOf(DateTimeParseException.class)
                 .hasMessageContaining(
                         "Failed to evaluate projection expression `CAST(`TB`.`castFloat` AS TIMESTAMP(3))` for column `castTimestamp` in table `my_company.my_branch.data_cast`.\n"
                                 + "\tCompiled expression: castToTimestamp($0, __time_zone__)\n"
                                 + "\tColumn name map: {$0 -> castFloat}")
-                .hasRootCauseMessage("Text '1.0' could not be parsed at index 0");
+                .hasRootCauseMessage("Unable to parse given string as timestamp: 1.0");
+
         transformFunctionEventEventOperatorTestHarness.close();
     }