[FLINK-39633][postgres] Apply spotless format

Author: JNSimba

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceScanFetcher.java

@@ -269,14 +269,11 @@ boolean isChangeRecordInChunkRange(SourceRecord record) {
         // Skip records of other captured tables; their schema may not be loaded yet
         // and their PKs do not align with this chunk's bounds.
         TableId recordTableId = taskContext.getTableId(record);
-        if (recordTableId == null
-                || !recordTableId.equals(currentSnapshotSplit.getTableId())) {
+        if (recordTableId == null || !recordTableId.equals(currentSnapshotSplit.getTableId())) {
             return false;
         }
         return taskContext.isRecordBetween(
-                record,
-                currentSnapshotSplit.getSplitStart(),
-                currentSnapshotSplit.getSplitEnd());
+                record, currentSnapshotSplit.getSplitStart(), currentSnapshotSplit.getSplitEnd());
     }
 
     @VisibleForTesting

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceScanFetcherTest.java

@@ -41,12 +41,11 @@ class IncrementalSourceScanFetcherTest {
     private static final TableId OTHER_TABLE = TableId.parse("test_db.table_b");
 
     /**
-     * Reproduces the NPE seen in PostgreSQL backfill when the WAL stream carries change records
-     * for a captured table other than the one currently being snapshotted. Before the fix, the
-     * fetcher passed the foreign-table record to {@code isRecordBetween}, which dereferenced a
-     * null Debezium {@code Table} from the schema cache and threw NPE. After the fix, the
-     * foreign-table record is filtered out by tableId and {@code isRecordBetween} is never
-     * invoked.
+     * Reproduces the NPE seen in PostgreSQL backfill when the WAL stream carries change records for
+     * a captured table other than the one currently being snapshotted. Before the fix, the fetcher
+     * passed the foreign-table record to {@code isRecordBetween}, which dereferenced a null
+     * Debezium {@code Table} from the schema cache and threw NPE. After the fix, the foreign-table
+     * record is filtered out by tableId and {@code isRecordBetween} is never invoked.
      */
     @Test
     void testIsChangeRecordInChunkRangeFiltersOutForeignTableRecord() {
@@ -105,9 +104,7 @@ void testIsChangeRecordInChunkRangeIgnoresNonDataChangeRecord() {
 
     private static SnapshotSplit newSnapshotSplit(TableId tableId) {
         RowType splitKeyType =
-                (RowType)
-                        DataTypes.ROW(DataTypes.FIELD("id", DataTypes.BIGINT()))
-                                .getLogicalType();
+                (RowType) DataTypes.ROW(DataTypes.FIELD("id", DataTypes.BIGINT())).getLogicalType();
         return new SnapshotSplit(
                 tableId,
                 0,