[FLINK-38838] Update spotless style version to AOSP 1.24.0

Author: yuxiqian

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryFormat.java

@@ -35,13 +35,15 @@ public interface BinaryFormat {
      * to the data, and 4-bytes length of data. Data is stored in variable-length part.
      */
     int MAX_FIX_PART_DATA_SIZE = 7;
+
     /**
      * To get the mark in highest bit of long. Form: 10000000 00000000 ... (8 bytes)
      *
      * <p>This is used to decide whether the data is stored in fixed-length part or variable-length
      * part. see {@link #MAX_FIX_PART_DATA_SIZE} for more information.
      */
     long HIGHEST_FIRST_BIT = 0x80L << 56;
+
     /**
      * To get the 7 bits length in second bit to eighth bit out of a long. Form: 01111111 00000000
      * ... (8 bytes)

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/ParsingException.java

@@ -24,7 +24,9 @@ public class ParsingException extends RuntimeException {
 
     private final Position position;
 
-    /** @param position the position of the error; never null */
+    /**
+     * @param position the position of the error; never null
+     */
     public ParsingException(Position position) {
         super();
         this.position = position;

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java

@@ -76,6 +76,7 @@ public String toString() {
     private final boolean caseSensitive;
     private final Tokenizer tokenizer;
     private List<Token> tokens;
+
     /**
      * This class navigates the Token objects using this iterator. However, because it very often
      * needs to access the "current token" in the "consume(...)" and "canConsume(...)" and

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Preconditions.java

@@ -129,6 +129,7 @@ public static void checkArgument(
             throw new IllegalArgumentException(format(errorMessageTemplate, errorMessageArgs));
         }
     }
+
     // ------------------------------------------------------------------------
     //  Boolean Condition Checking (State)
     // ------------------------------------------------------------------------

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TypeCheckUtils.java

@@ -103,7 +103,7 @@ public static boolean isMutable(DataType type) {
         switch (type.getTypeRoot()) {
             case CHAR:
             case VARCHAR: // The internal representation of String is BinaryString which is
-                // mutable
+            // mutable
             case ARRAY:
             case MAP:
             case ROW:

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/config/ElasticsearchSinkOptions.java

@@ -99,42 +99,58 @@ public ElasticsearchSinkOptions(
         this.shardingSeparator = shardingSeparator;
     }
 
-    /** @return the maximum batch size */
+    /**
+     * @return the maximum batch size
+     */
     public int getMaxBatchSize() {
         return maxBatchSize;
     }
 
-    /** @return the maximum number of in-flight requests */
+    /**
+     * @return the maximum number of in-flight requests
+     */
     public int getMaxInFlightRequests() {
         return maxInFlightRequests;
     }
 
-    /** @return the maximum number of buffered requests */
+    /**
+     * @return the maximum number of buffered requests
+     */
     public int getMaxBufferedRequests() {
         return maxBufferedRequests;
     }
 
-    /** @return the maximum batch size in bytes */
+    /**
+     * @return the maximum batch size in bytes
+     */
     public long getMaxBatchSizeInBytes() {
         return maxBatchSizeInBytes;
     }
 
-    /** @return the maximum time in buffer in milliseconds */
+    /**
+     * @return the maximum time in buffer in milliseconds
+     */
     public long getMaxTimeInBufferMS() {
         return maxTimeInBufferMS;
     }
 
-    /** @return the maximum record size in bytes */
+    /**
+     * @return the maximum record size in bytes
+     */
     public long getMaxRecordSizeInBytes() {
         return maxRecordSizeInBytes;
     }
 
-    /** @return the network configuration */
+    /**
+     * @return the network configuration
+     */
     public NetworkConfig getNetworkConfig() {
         return networkConfig;
     }
 
-    /** @return the list of Elasticsearch hosts */
+    /**
+     * @return the list of Elasticsearch hosts
+     */
     public List<HttpHost> getHosts() {
         return networkConfig.getHosts();
     }

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncWriter.java

@@ -61,11 +61,13 @@ public class Elasticsearch8AsyncWriter<InputT> extends AsyncSinkWriter<InputT, O
     private boolean close = false;
 
     private final Counter numRecordsOutErrorsCounter;
+
     /**
      * A counter to track number of records that are returned by Elasticsearch as failed and then
      * retried by this writer.
      */
     private final Counter numRecordsSendPartialFailureCounter;
+
     /** A counter to track the number of bulk requests that are sent to Elasticsearch. */
     private final Counter numRequestSubmittedCounter;
 

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java

@@ -94,6 +94,7 @@ public class SessionManageOperator extends AbstractStreamOperator<Event>
 
     private transient Future<CoordinationResponse> snapshotFlushSuccess;
     private transient int indexOfThisSubtask;
+
     /**
      * trigger endOfInput is ahead of prepareSnapshotPreBarrier, so we need this flag to handle when
      * endOfInput, send WaitForSuccessRequest in advance.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SessionCommitCoordinateHelper.java

@@ -69,6 +69,7 @@ public class SessionCommitCoordinateHelper {
     private static final Logger LOG = LoggerFactory.getLogger(SessionCommitCoordinateHelper.class);
     private final Queue<String>[] toCommitSessionIds;
     private final Map<String, CompletableFuture<CoordinationResponse>> toCommitFutures;
+
     /**
      * If any string is {@link Constant#END_OF_SESSION}, it should be considered larger than any
      * other non-{@link Constant#END_OF_SESSION} string.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseCatalogException.java

@@ -19,12 +19,16 @@
 
 /** A catalog-related, runtime exception. */
 public class OceanBaseCatalogException extends RuntimeException {
-    /** @param message the detail message. */
+    /**
+     * @param message the detail message.
+     */
     public OceanBaseCatalogException(String message) {
         super(message);
     }
 
-    /** @param cause the cause. */
+    /**
+     * @param cause the cause.
+     */
     public OceanBaseCatalogException(Throwable cause) {
         super(cause);
     }