This is an automated email from the ASF dual-hosted git repository. healchow pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
commit 0c056bb9e26e2db99b4b493c95935647863d783e Author: Schnapps <[email protected]> AuthorDate: Thu Apr 28 17:05:06 2022 +0800 [INLONG-4005][Sort] Remove some inappropriate comment and code (#4006) --- .../inlong/sort/singletenant/flink/parser/MetaFieldSyncTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/parser/MetaFieldSyncTest.java b/inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/parser/MetaFieldSyncTest.java index 8e45babf7..103e13a15 100644 --- a/inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/parser/MetaFieldSyncTest.java +++ b/inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/parser/MetaFieldSyncTest.java @@ -56,7 +56,7 @@ import java.util.List; import java.util.stream.Collectors; /** - * Test for {@link FlinkSqlParser#parseMetaField(Node, BuiltInFieldInfo, StringBuilder)} + * Test for mysql meta field */ public class MetaFieldSyncTest extends AbstractTestBase { @@ -79,8 +79,8 @@ public class MetaFieldSyncTest extends AbstractTestBase { new BuiltInFieldInfo("up_before", new TimestampFormatInfo(), BuiltInField.METADATA_UPDATE_BEFORE) ); return new MySqlExtractNode("1", "mysql_input", fields, null, null, "id", - Arrays.asList("worker", "worker2"), "localhost", "root", "168998", - "wedata_datastudio", null, null, null, null); + Arrays.asList("sort"), "localhost", "inlong", "password", + "test", null, null, null, null); } private KafkaLoadNode buildKafkaNode() { @@ -136,7 +136,7 @@ public class MetaFieldSyncTest extends AbstractTestBase { ); List<FilterFunction> filters = Arrays.asList(new SingleValueFilterFunction(EmptyOperator.getInstance(), new FieldInfo("name", new StringFormatInfo()), - EqualOperator.getInstance(), new StringConstantParam("yunqingmo"))); + EqualOperator.getInstance(), new StringConstantParam("test"))); KafkaLoadNode node = new KafkaLoadNode("2", "kafka_output2", fields, relations, null, "worker123", "localhost:9092", new JsonFormat(), null,
