You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by es...@apache.org on 2022/07/17 12:29:27 UTC
[bahir-flink] 06/16: fix: update KuduDynamicSinkTest
This is an automated email from the ASF dual-hosted git repository.
eskabetxe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git
commit 10b9c361c5cee65af3a72ed4f9fc66ebbee49714
Author: min <40...@users.noreply.github.com>
AuthorDate: Thu May 19 18:59:07 2022 +0800
fix: update KuduDynamicSinkTest
---
.../apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java
index f889c7a..a5fc007 100644
--- a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java
+++ b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java
@@ -80,7 +80,7 @@ public class KuduDynamicSinkTest extends KuduTestBase {
+ "','kudu.flush-interval'='1000"
+ "','kudu.operation-timeout'='500"
+ "','kudu.ignore-not-found'='true"
- + "','kudu.ignore-not-found'='true"
+ + "','kudu.ignore-not-found'='true'"
+ ")";
tEnv.executeSql(createSql);
tEnv.executeSql("insert into " + INPUT_TABLE + " values(1006,'test title','test author',10.1,10)");