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 <[email protected]> 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)");
