fix comment format

Author: loserwang1024

fluss-flink/fluss-flink-2.2/src/test/java/org/apache/fluss/flink/source/Flink22TableSourceITCase.java

@@ -39,8 +39,7 @@ public class Flink22TableSourceITCase extends FlinkTableSourceITCase {
 
     @Test
     void testDeltaJoin() throws Exception {
-        // start two jobs for this test: one for DML involving the delta join, and the
-        // other for DQL
+        // start two jobs for this test: one for DML involving the delta join, and the other for DQL
         // to query the results of the sink table
         tEnv.getConfig().set(ExecutionConfigOptions.TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM, 2);
 
@@ -148,8 +147,7 @@ void testDeltaJoin() throws Exception {
 
     @Test
     void testDeltaJoinWithProjectionAndFilter() throws Exception {
-        // start two jobs for this test: one for DML involving the delta join, and the
-        // other for DQL
+        // start two jobs for this test: one for DML involving the delta join, and the other for DQL
         // to query the results of the sink table
         tEnv.getConfig().set(ExecutionConfigOptions.TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM, 2);
 

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java

@@ -828,8 +828,7 @@ private CatalogTable wrapWithIndexes(CatalogTable table, TableInfo tableInfo) {
 
         // Judge whether we can do prefix lookup.
         List<String> bucketKeys = tableInfo.getBucketKeys();
-        // For partition table, the physical primary key is the primary key that
-        // excludes the
+        // For partition table, the physical primary key is the primary key that excludes the
         // partition key
         List<String> physicalPrimaryKeys = tableInfo.getPhysicalPrimaryKeys();
         List<String> indexKeys = new ArrayList<>();

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/sink/FlinkSink.java

@@ -124,8 +124,7 @@ public AppendSinkWriter<InputT> createWriter(MailboxExecutor mailboxExecutor) {
 
         @Override
         public DataStream<InputT> addPreWriteTopology(DataStream<InputT> input) {
-            // For append only sink, we will do bucket shuffle only if bucket keys are not
-            // empty.
+            // For append only sink, we will do bucket shuffle only if bucket keys are not empty.
             if (!bucketKeys.isEmpty() && shuffleByBucketId) {
                 return partition(
                         input,

fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogTest.java

@@ -332,8 +332,7 @@ void testCreateAlreadyExistsLakeTable() throws Exception {
         // drop fluss table
         catalog.dropTable(lakeTablePath, false);
         assertThat(catalog.tableExists(lakeTablePath)).isFalse();
-        // create the table again should be ok, because the existing lake table is
-        // matched
+        // create the table again should be ok, because the existing lake table is matched
         catalog.createTable(lakeTablePath, table, false);
     }
 
@@ -847,7 +846,7 @@ void testConnectionFailureHandling() {
 
     @Test
     void testStatisticsOperations() throws Exception {
-        // Statistics testing
+        //  Statistics testing
         CatalogTable table = newCatalogTable(Collections.emptyMap());
         ObjectPath tablePath = new ObjectPath(DEFAULT_DB, "statsTable");
         catalog.createTable(tablePath, table, false);