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