diff --git a/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/OracleExtractSqlParseTest.java b/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/OracleExtractSqlParseTest.java index 335afcdd55c..133b0e8e2d1 100644 --- a/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/OracleExtractSqlParseTest.java +++ b/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/OracleExtractSqlParseTest.java @@ -73,7 +73,7 @@ private OracleExtractNode buildOracleExtractNode() { return new OracleExtractNode("1", "oracle_input", fields, null, properties, "ID", "localhost", "flinkuser", "flinkpw", "xE", - "flinkuser", "table", 1521, null); + "flinkuser", "flinkuser.table", 1521, null); } private Node buildKafkaLoadNode() {