You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/04/28 11:37:39 UTC
[incubator-inlong] 08/08: [INLONG-4005][Sort] Remove some inappropriate comment and code (#4006)
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 <zp...@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,