[incubator-inlong] branch master updated: [INLONG-4005][Sort] Remove some inappropriate comment and code (#4006)

[healchow]

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


The following commit(s) were added to refs/heads/master by this push:
     new b0b81976a [INLONG-4005][Sort] Remove some inappropriate comment and 
code (#4006)
b0b81976a is described below

commit b0b81976ac53b947aae21eec0b11abf62d3a1cdc
Author: Schnapps <zpen...@connect.ust.hk>
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,