[Fix]:code style

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java

@@ -112,6 +112,7 @@ private void close() {
 
     /**
      * Open a scanner for reading Doris data.
+     *
      * @param openParams thrift struct to required by request
      * @return scan open result
      * @throws ConnectedFailedException throw if cannot connect to Doris BE
@@ -147,6 +148,7 @@ public TScanOpenResult openScanner(TScanOpenParams openParams) throws ConnectedF
 
     /**
      * get next row batch from Doris BE
+     *
      * @param nextBatchParams thrift struct to required by request
      * @return scan batch result
      * @throws ConnectedFailedException throw if cannot connect to Doris BE
@@ -161,7 +163,7 @@ public TScanBatchResult getNext(TScanNextBatchParams nextBatchParams) throws Dor
         for (int attempt = 0; attempt < retries; ++attempt) {
             logger.debug("Attempt {} to getNext {}.", attempt, routing);
             try {
-                result  = client.get_next(nextBatchParams);
+                result = client.get_next(nextBatchParams);
                 if (result == null) {
                     logger.warn("GetNext result from {} is null.", routing);
                     continue;
@@ -189,6 +191,7 @@ public TScanBatchResult getNext(TScanNextBatchParams nextBatchParams) throws Dor
 
     /**
      * close an scanner.
+     *
      * @param closeParams thrift struct to required by request
      */
     public void closeScanner(TScanCloseParams closeParams) {

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java

@@ -21,7 +21,7 @@
 import java.io.Serializable;
 
 /**
- *  Doris connection options.
+ * Doris connection options.
  */
 public class DorisConnectionOptions implements Serializable {
 

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java

@@ -26,17 +26,19 @@
 /**
  * JDBC sink batch options.
  */
-public class DorisExecutionOptions  implements Serializable {
+public class DorisExecutionOptions implements Serializable {
     private static final long serialVersionUID = 1L;
 
     private final Integer batchSize;
     private final Integer maxRetries;
     private final Long batchIntervalMs;
 
-    /** Properties for the StreamLoad. */
+    /**
+     * Properties for the StreamLoad.
+     */
     private final Properties streamLoadProp;
 
-    public DorisExecutionOptions(Integer batchSize, Integer maxRetries,Long batchIntervalMs,Properties streamLoadProp) {
+    public DorisExecutionOptions(Integer batchSize, Integer maxRetries, Long batchIntervalMs, Properties streamLoadProp) {
         Preconditions.checkArgument(maxRetries >= 0);
         this.batchSize = batchSize;
         this.maxRetries = maxRetries;
@@ -94,7 +96,7 @@ public Builder setStreamLoadProp(Properties streamLoadProp) {
         }
 
         public DorisExecutionOptions build() {
-            return new DorisExecutionOptions(batchSize,maxRetries,batchIntervalMs,streamLoadProp);
+            return new DorisExecutionOptions(batchSize, maxRetries, batchIntervalMs, streamLoadProp);
         }
     }
 

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java

@@ -25,7 +25,7 @@
 /**
  * Options for the Doris connector.
  */
-public class DorisOptions extends DorisConnectionOptions{
+public class DorisOptions extends DorisConnectionOptions {
 
     private static final long serialVersionUID = 1L;
 

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java

@@ -22,7 +22,7 @@
 /**
  * Doris read Options
  */
-public class DorisReadOptions  implements Serializable {
+public class DorisReadOptions implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
@@ -35,7 +35,7 @@ public class DorisReadOptions  implements Serializable {
     private Integer requestRetries;
     private Integer requestBatchSize;
     private Long execMemLimit;
-    private Integer  deserializeQueueSize;
+    private Integer deserializeQueueSize;
     private Boolean deserializeArrowAsync;
 
     public DorisReadOptions(String readFields, String filterQuery, Integer requestTabletSize, Integer requestConnectTimeoutMs, Integer requestReadTimeoutMs,
@@ -117,7 +117,7 @@ public static class Builder {
         private Integer requestRetries;
         private Integer requestBatchSize;
         private Long execMemLimit;
-        private Integer  deserializeQueueSize;
+        private Integer deserializeQueueSize;
         private Boolean deserializeArrowAsync;
 
 
@@ -177,7 +177,7 @@ public Builder setDeserializeArrowAsync(Boolean deserializeArrowAsync) {
         }
 
         public DorisReadOptions build() {
-            return new DorisReadOptions(readFields,filterQuery,requestTabletSize,requestConnectTimeoutMs,requestReadTimeoutMs,requestQueryTimeoutS,requestRetries,requestBatchSize,execMemLimit,deserializeQueueSize,deserializeArrowAsync);
+            return new DorisReadOptions(readFields, filterQuery, requestTabletSize, requestConnectTimeoutMs, requestReadTimeoutMs, requestQueryTimeoutS, requestRetries, requestBatchSize, execMemLimit, deserializeQueueSize, deserializeArrowAsync);
         }
     }
 

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java

@@ -38,15 +38,15 @@
 
 public class DorisSourceFunction<T> extends RichSourceFunction<T> implements ResultTypeQueryable<T> {
 
-    private  static final Logger logger = LoggerFactory.getLogger(DorisSourceFunction.class);
+    private static final Logger logger = LoggerFactory.getLogger(DorisSourceFunction.class);
 
     private DorisDeserializationSchema deserializer;
     private DorisOptions options;
     private DorisReadOptions readOptions;
-    private List<PartitionDefinition>  dorisPartitions;
+    private List<PartitionDefinition> dorisPartitions;
     private ScalaValueReader scalaValueReader;
 
-    public DorisSourceFunction(DorisStreamOptions streamOptions, DorisDeserializationSchema deserializer)  {
+    public DorisSourceFunction(DorisStreamOptions streamOptions, DorisDeserializationSchema deserializer) {
         this.deserializer = deserializer;
         this.options = streamOptions.getOptions();
         this.readOptions = streamOptions.getReadOptions();
@@ -55,14 +55,14 @@ public DorisSourceFunction(DorisStreamOptions streamOptions, DorisDeserializatio
     @Override
     public void open(Configuration parameters) throws Exception {
         super.open(parameters);
-        this.dorisPartitions =  RestService.findPartitions(options,readOptions,logger);
+        this.dorisPartitions = RestService.findPartitions(options, readOptions, logger);
     }
 
     @Override
-    public void run(SourceContext sourceContext) throws Exception{
-        for(PartitionDefinition partitions : dorisPartitions){
-            scalaValueReader = new ScalaValueReader(partitions, options,readOptions);
-            while (scalaValueReader.hasNext()){
+    public void run(SourceContext sourceContext) throws Exception {
+        for (PartitionDefinition partitions : dorisPartitions) {
+            scalaValueReader = new ScalaValueReader(partitions, options, readOptions);
+            while (scalaValueReader.hasNext()) {
                 Object next = scalaValueReader.next();
                 sourceContext.collect(next);
             }

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java

@@ -18,10 +18,11 @@
 
 
 import org.apache.flink.api.common.typeinfo.TypeInformation;
+
 import java.util.List;
 
 
-public class SimpleListDeserializationSchema implements DorisDeserializationSchema{
+public class SimpleListDeserializationSchema implements DorisDeserializationSchema {
 
     @Override
     public TypeInformation getProducedType() {

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisException.java

@@ -21,18 +21,22 @@ public class DorisException extends Exception {
     public DorisException() {
         super();
     }
+
     public DorisException(String message) {
         super(message);
     }
+
     public DorisException(String message, Throwable cause) {
         super(message, cause);
     }
+
     public DorisException(Throwable cause) {
         super(cause);
     }
+
     protected DorisException(String message, Throwable cause,
-                        boolean enableSuppression,
-                        boolean writableStackTrace) {
+                             boolean enableSuppression,
+                             boolean writableStackTrace) {
         super(message, cause, enableSuppression, writableStackTrace);
     }
 }

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java

@@ -17,4 +17,5 @@
 
 package org.apache.doris.flink.exception;
 
-public class ShouldNeverHappenException extends DorisException { }
+public class ShouldNeverHappenException extends DorisException {
+}

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/StreamLoadException.java

@@ -21,15 +21,19 @@ public class StreamLoadException extends Exception {
     public StreamLoadException() {
         super();
     }
+
     public StreamLoadException(String message) {
         super(message);
     }
+
     public StreamLoadException(String message, Throwable cause) {
         super(message, cause);
     }
+
     public StreamLoadException(Throwable cause) {
         super(cause);
     }
+
     protected StreamLoadException(String message, Throwable cause,
                                   boolean enableSuppression,
                                   boolean writableStackTrace) {

extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java

@@ -103,7 +103,7 @@ public int compareTo(PartitionDefinition o) {
         similar.retainAll(o.tabletIds);
         diffSelf.removeAll(similar);
         diffOther.removeAll(similar);
-        if  (diffSelf.size() == 0) {
+        if (diffSelf.size() == 0) {
             return 0;
         }
         long diff = Collections.min(diffSelf) - Collections.min(diffOther);