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 06d8eb9911ba1520f8535cecca90c35467323ed4 Author: min <[email protected]> AuthorDate: Thu May 19 16:49:35 2022 +0800 fix: kudu.master config -> kudu.masters --- .../flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java | 2 +- .../flink/connectors/kudu/table/dynamic/KuduDynamicSourceTest.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) 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 f74a553..a024b4d 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 @@ -72,7 +72,7 @@ public class KuduDynamicSinkTest extends KuduTestBase { + "quantity int" + ") WITH (" + " 'connector'='kudu'," - + " 'kudu.master'='" + + " 'kudu.masters'='" + getMasterAddress() + "'," + " 'kudu.table'='" diff --git a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSourceTest.java b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSourceTest.java index 28de2da..1504c7e 100644 --- a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSourceTest.java +++ b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSourceTest.java @@ -71,7 +71,7 @@ public class KuduDynamicSourceTest extends KuduTestBase { + "quantity int" + ") WITH (" + " 'connector'='kudu'," - + " 'kudu.master'='" + + " 'kudu.masters'='" + getMasterAddress() + "'," + " 'kudu.table'='" @@ -98,7 +98,7 @@ public class KuduDynamicSourceTest extends KuduTestBase { + "quantity int" + ") WITH (" + " 'connector'='kudu'," - + " 'kudu.master'='" + + " 'kudu.masters'='" + getMasterAddress() + "'," + " 'kudu.table'='" @@ -142,7 +142,7 @@ public class KuduDynamicSourceTest extends KuduTestBase { + "quantity int" + ") WITH (" + " 'connector'='kudu'," - + " 'kudu.master'='" + + " 'kudu.masters'='" + getMasterAddress() + "'," + " 'kudu.table'='"
