Fix FlussConfig Utils class is not in the correct directory and does not have a private instance

Author: ThorneANN

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.sink.FlussConfigUtils.parseBucketKeys;
-import static org.apache.flink.cdc.connectors.fluss.sink.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 {

…nectors/fluss/sink/FlussConfigUtils.java …ectors/fluss/utils/FlussConfigUtils.javaflink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussConfigUtils.java renamed 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 flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussConfigUtils.java renamed 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

@@ -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;
 
@@ -24,7 +24,7 @@
 import java.util.List;
 import java.util.Map;
 
-/** Utils for parsing fluss yaml sink options. */
+/** Utils for parsing fluss Yaml sink options. */
 public class FlussConfigUtils {
     public static Map<String, List<String>> parseBucketKeys(@Nullable String rawValue)
             throws IllegalArgumentException {
@@ -78,4 +78,6 @@ public static Map<String, Integer> parseBucketNumber(@Nullable String rawValue)
         }
         return result;
     }
+
+    private FlussConfigUtils() {}
 }