fix checkstyle error

jerry-024 · Dec 19, 2024 · ba690d6 · ba690d6
1 parent da23974
commit ba690d6
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 6 deletions.
diff --git a/...-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java b/...-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java
@@ -178,7 +178,8 @@ public void processElement(StreamRecord<CdcMultiplexRecord> element) throws Exce
         }
     }
 
-    private FileStoreTable getTable(Identifier tableId) throws InterruptedException, Catalog.TableNoPermissionException {
+    private FileStoreTable getTable(Identifier tableId)
+            throws InterruptedException, Catalog.TableNoPermissionException {
         FileStoreTable table = tables.get(tableId);
         if (table == null) {
             while (true) {

diff --git a/...imon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java b/...imon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java
@@ -177,7 +177,9 @@ private void buildForDividedMode() {
                     }
                 }
             }
-        } catch (Catalog.DatabaseNotExistException | Catalog.TableNotExistException | Catalog.TableNoPermissionException e) {
+        } catch (Catalog.DatabaseNotExistException
+                | Catalog.TableNotExistException
+                | Catalog.TableNoPermissionException e) {
             throw new RuntimeException(e);
         }
 

diff --git a/...ink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CopyFileOperator.java b/...ink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CopyFileOperator.java
@@ -82,7 +82,8 @@ public void processElement(StreamRecord<CloneFileInfo> streamRecord) throws Exce
                             try {
                                 return pathOfTable(
                                         sourceCatalog.getTable(Identifier.fromString(key)));
-                            } catch (Catalog.TableNotExistException | Catalog.TableNoPermissionException e) {
+                            } catch (Catalog.TableNotExistException
+                                    | Catalog.TableNoPermissionException e) {
                                 throw new RuntimeException(e);
                             }
                         });
@@ -93,7 +94,8 @@ public void processElement(StreamRecord<CloneFileInfo> streamRecord) throws Exce
                             try {
                                 return pathOfTable(
                                         targetCatalog.getTable(Identifier.fromString(key)));
-                            } catch (Catalog.TableNotExistException | Catalog.TableNoPermissionException e) {
+                            } catch (Catalog.TableNotExistException
+                                    | Catalog.TableNoPermissionException e) {
                                 throw new RuntimeException(e);
                             }
                         });

diff --git a/...mon/src/main/java/org/apache/paimon/flink/source/operator/CombinedUnawareBatchSource.java b/...mon/src/main/java/org/apache/paimon/flink/source/operator/CombinedUnawareBatchSource.java
@@ -178,9 +178,9 @@ private static Long getPartitionInfo(
                                                 PartitionEntry::lastFileCreationTime));
                 multiTablesPartitionInfo.put(tableIdentifier, partitionInfo);
             } catch (Catalog.TableNotExistException e) {
-                LOGGER.error(String.format("table: %s not found.", tableIdentifier.getFullName()));
+                LOGGER.error("table: {} not found.", tableIdentifier.getFullName());
             } catch (Catalog.TableNoPermissionException e) {
-                LOGGER.error(String.format("table: %s no permission.", tableIdentifier.getFullName()));
+                LOGGER.error("table: {} no permission.", tableIdentifier.getFullName());
             }
         }
         return partitionInfo.get(partition);