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:25 UTC
[bahir-flink] 04/16: fix: kudu.master config -> kudu.masters
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 <40...@users.noreply.github.com>
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'='"