[fix] fix code style

Author: gnehil

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

@@ -63,5 +63,4 @@ public interface ConfigurationOptions {
 
     String SINK_HTTP_UTF8_CHARSET = "sink.http-utf8-charset";
     Boolean SINK_HTTP_UTF8_CHARSET_DEFAULT = false;
-
 }

flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java

@@ -58,11 +58,12 @@ public HttpUtil(DorisReadOptions readOptions, boolean httpUtf8Charset) {
     private void settingStreamHttpClientBuilder() {
         ConnectionConfig connectionConfig = ConnectionConfig.DEFAULT;
         if (httpUtf8Charset) {
-            connectionConfig = ConnectionConfig.custom()
-                    .setCharset(StandardCharsets.UTF_8)
-                    .setMalformedInputAction(CodingErrorAction.REPLACE)
-                    .setUnmappableInputAction(CodingErrorAction.REPLACE)
-                    .build();
+            connectionConfig =
+                    ConnectionConfig.custom()
+                            .setCharset(StandardCharsets.UTF_8)
+                            .setMalformedInputAction(CodingErrorAction.REPLACE)
+                            .setUnmappableInputAction(CodingErrorAction.REPLACE)
+                            .build();
         }
         this.httpClientBuilder =
                 HttpClients.custom()
@@ -103,11 +104,12 @@ public CloseableHttpClient getHttpClient() {
     public HttpClientBuilder getHttpClientBuilderForBatch() {
         ConnectionConfig connectionConfig = ConnectionConfig.DEFAULT;
         if (httpUtf8Charset) {
-            connectionConfig = ConnectionConfig.custom()
-                    .setCharset(StandardCharsets.UTF_8)
-                    .setMalformedInputAction(CodingErrorAction.REPLACE)
-                    .setUnmappableInputAction(CodingErrorAction.REPLACE)
-                    .build();
+            connectionConfig =
+                    ConnectionConfig.custom()
+                            .setCharset(StandardCharsets.UTF_8)
+                            .setMalformedInputAction(CodingErrorAction.REPLACE)
+                            .setUnmappableInputAction(CodingErrorAction.REPLACE)
+                            .build();
         }
         return HttpClients.custom()
                 .setDefaultConnectionConfig(connectionConfig)

flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java

@@ -172,7 +172,9 @@ public DorisBatchStreamLoad(
         this.started = new AtomicBoolean(true);
         this.loadExecutorService.execute(loadAsyncExecutor);
         this.subTaskId = subTaskId;
-        this.httpClientBuilder = new HttpUtil(dorisReadOptions, executionOptions.isHttpUtf8Charset()).getHttpClientBuilderForBatch();
+        this.httpClientBuilder =
+                new HttpUtil(dorisReadOptions, executionOptions.isHttpUtf8Charset())
+                        .getHttpClientBuilderForBatch();
     }
 
     /**

flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java

@@ -70,7 +70,8 @@ public DorisCommitter(
                 dorisOptions,
                 dorisReadOptions,
                 executionOptions,
-                new HttpUtil(dorisReadOptions, executionOptions.isHttpUtf8Charset()).getHttpClient());
+                new HttpUtil(dorisReadOptions, executionOptions.isHttpUtf8Charset())
+                        .getHttpClient());
     }
 
     public DorisCommitter(

flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java

@@ -310,7 +310,8 @@ public DorisStreamLoad getStreamLoader(String tableKey) {
                                 dorisOptions,
                                 executionOptions,
                                 labelGenerator,
-                                new HttpUtil(dorisReadOptions, executionOptions.isHttpUtf8Charset()).getHttpClient()));
+                                new HttpUtil(dorisReadOptions, executionOptions.isHttpUtf8Charset())
+                                        .getHttpClient()));
     }
 
     /** Http throws an exception actively, there is no need to check regularly. */

flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java

@@ -40,9 +40,7 @@
 import static org.apache.doris.flink.cfg.ConfigurationOptions.DORIS_TABLET_SIZE_DEFAULT;
 import static org.apache.doris.flink.cfg.ConfigurationOptions.DORIS_THRIFT_MAX_MESSAGE_SIZE_DEFAULT;
 
-/**
- * Options for the Doris connector.
- */
+/** Options for the Doris connector. */
 @PublicEvolving
 public class DorisConfigOptions {
 
@@ -347,6 +345,6 @@ public static Properties getStreamLoadProp(Map<String, String> tableOptions) {
             ConfigOptions.key("sink.http-utf8-charset")
                     .booleanType()
                     .defaultValue(false)
-                    .withDescription("Set sink http client default charset to utf8 for support unicode characters in header, the default value is false");
-
+                    .withDescription(
+                            "Set sink http client default charset to utf8 for support unicode characters in header, the default value is false");
 }

flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java

@@ -74,6 +74,7 @@
 import static org.apache.doris.flink.table.DorisConfigOptions.SINK_ENABLE_BATCH_MODE;
 import static org.apache.doris.flink.table.DorisConfigOptions.SINK_ENABLE_DELETE;
 import static org.apache.doris.flink.table.DorisConfigOptions.SINK_FLUSH_QUEUE_SIZE;
+import static org.apache.doris.flink.table.DorisConfigOptions.SINK_HTTP_UTF8_CHARSET;
 import static org.apache.doris.flink.table.DorisConfigOptions.SINK_IGNORE_COMMIT_ERROR;
 import static org.apache.doris.flink.table.DorisConfigOptions.SINK_IGNORE_UPDATE_BEFORE;
 import static org.apache.doris.flink.table.DorisConfigOptions.SINK_LABEL_PREFIX;
@@ -86,7 +87,6 @@
 import static org.apache.doris.flink.table.DorisConfigOptions.TABLE_IDENTIFIER;
 import static org.apache.doris.flink.table.DorisConfigOptions.USERNAME;
 import static org.apache.doris.flink.table.DorisConfigOptions.USE_FLIGHT_SQL;
-import static org.apache.doris.flink.table.DorisConfigOptions.SINK_HTTP_UTF8_CHARSET;
 
 /**
  * The {@link DorisDynamicTableFactory} translates the catalog table to a table source.

flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkITCase.java

@@ -801,14 +801,15 @@ public void testSinkUnicodeColumn() throws Exception {
                 dorisBuilder.build(),
                 executionBuilder.build(),
                 new String[] {
-                        new ObjectMapper().writeValueAsString(row1),
-                        new ObjectMapper().writeValueAsString(row2)
+                    new ObjectMapper().writeValueAsString(row1),
+                    new ObjectMapper().writeValueAsString(row2)
                 });
 
         Thread.sleep(10000);
         List<String> expected = Arrays.asList("doris1,1", "doris2,2");
-        String query = String.format("select `名称`,`年龄` from %s.%s order by 1", DATABASE, TABLE_UNICODE_COLUMN);
+        String query =
+                String.format(
+                        "select `名称`,`年龄` from %s.%s order by 1", DATABASE, TABLE_UNICODE_COLUMN);
         ContainerUtils.checkResult(getDorisQueryConnection(), LOG, expected, query, 2);
     }
-
 }