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:37 UTC
[bahir-flink] 16/16: fix: reformat code style
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 80a57e94ab09164eab1bbdc7d4d694eae4f5edb6
Author: min <40...@users.noreply.github.com>
AuthorDate: Mon Jun 13 16:06:34 2022 +0800
fix: reformat code style
---
.../kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java
index 3a24372..6fab41f 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java
@@ -112,14 +112,14 @@ public class KuduDynamicTableSourceSinkFactory implements DynamicTableSourceFact
.key("kudu.hash-partition-nums")
.intType()
.defaultValue(KUDU_REPLICAS.defaultValue() * 2)
- .withDescription("kudu's hash partition bucket nums,defaultValue is 2 * replica nums");
+ .withDescription("kudu's hash partition bucket nums, defaultValue is 2 * replica nums");
public static final ConfigOption<String> KUDU_PRIMARY_KEY_COLS =
ConfigOptions
.key("kudu.primary-key-columns")
.stringType()
.noDefaultValue()
- .withDescription("kudu's primary key,primary key must be ordered");
+ .withDescription("kudu's primary key, primary key must be ordered");
public static final ConfigOption<Integer> KUDU_SCAN_ROW_SIZE =
@@ -203,7 +203,7 @@ public class KuduDynamicTableSourceSinkFactory implements DynamicTableSourceFact
long kuduCacheTtl = config.get(KUDU_LOOKUP_CACHE_TTL);
int kuduMaxReties = config.get(KUDU_LOOKUP_MAX_RETRIES);
- // 构造kudu lookup options
+ // build kudu lookup options
KuduLookupOptions kuduLookupOptions = KuduLookupOptions.Builder.options().withCacheMaxSize(kuduCacheMaxRows)
.withCacheExpireMs(kuduCacheTtl)
.withMaxRetryTimes(kuduMaxReties)