From f6452fff7440436721c160352819294cb4ccf94b Mon Sep 17 00:00:00 2001 From: Thorne Date: Fri, 6 Mar 2026 16:36:06 +0800 Subject: [PATCH 1/2] private the utile config and remove configUtile in Utils dir --- .../cdc/connectors/fluss/factory/FlussDataSinkFactory.java | 4 ++-- .../connectors/fluss/{sink => utils}/FlussConfigUtils.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) rename flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/{sink => utils}/FlussConfigUtils.java (98%) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/factory/FlussDataSinkFactory.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/factory/FlussDataSinkFactory.java index 58e469d2de6..be76531f577 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/factory/FlussDataSinkFactory.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/factory/FlussDataSinkFactory.java @@ -32,8 +32,8 @@ import java.util.Map; import java.util.Set; -import static org.apache.flink.cdc.connectors.fluss.sink.FlussConfigUtils.parseBucketKeys; -import static org.apache.flink.cdc.connectors.fluss.sink.FlussConfigUtils.parseBucketNumber; +import static org.apache.flink.cdc.connectors.fluss.utils.FlussConfigUtils.parseBucketKeys; +import static org.apache.flink.cdc.connectors.fluss.utils.FlussConfigUtils.parseBucketNumber; import static org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions.BOOTSTRAP_SERVERS; import static org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions.BUCKET_KEY; import static org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions.BUCKET_NUMBER; diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussConfigUtils.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConfigUtils.java similarity index 98% rename from flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussConfigUtils.java rename to flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConfigUtils.java index 000cabe08bc..2414e81b44e 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussConfigUtils.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConfigUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.flink.cdc.connectors.fluss.sink; +package org.apache.flink.cdc.connectors.fluss.utils; import javax.annotation.Nullable; From 9c0e7efdcca362e7fafbc7bf302518c626644235 Mon Sep 17 00:00:00 2001 From: Thorne Date: Fri, 6 Mar 2026 16:37:47 +0800 Subject: [PATCH 2/2] private the utile config --- .../cdc/connectors/fluss/factory/FlussDataSinkFactory.java | 4 ++-- .../flink/cdc/connectors/fluss/utils/FlussConfigUtils.java | 2 ++ 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/factory/FlussDataSinkFactory.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/factory/FlussDataSinkFactory.java index be76531f577..ca3a6a98ef2 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/factory/FlussDataSinkFactory.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/factory/FlussDataSinkFactory.java @@ -32,13 +32,13 @@ import java.util.Map; import java.util.Set; -import static org.apache.flink.cdc.connectors.fluss.utils.FlussConfigUtils.parseBucketKeys; -import static org.apache.flink.cdc.connectors.fluss.utils.FlussConfigUtils.parseBucketNumber; import static org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions.BOOTSTRAP_SERVERS; import static org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions.BUCKET_KEY; import static org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions.BUCKET_NUMBER; import static org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions.CLIENT_PROPERTIES_PREFIX; import static org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions.TABLE_PROPERTIES_PREFIX; +import static org.apache.flink.cdc.connectors.fluss.utils.FlussConfigUtils.parseBucketKeys; +import static org.apache.flink.cdc.connectors.fluss.utils.FlussConfigUtils.parseBucketNumber; /** Factory for creating configured instances of {@link FlussDataSink}. */ public class FlussDataSinkFactory implements DataSinkFactory { diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConfigUtils.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConfigUtils.java index 2414e81b44e..42746d28c8d 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConfigUtils.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConfigUtils.java @@ -78,4 +78,6 @@ public static Map parseBucketNumber(@Nullable String rawValue) } return result; } + + private FlussConfigUtils() {} }