Fix compile.

Author: lvyanquan

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java

@@ -38,6 +38,7 @@
 import org.apache.paimon.memory.HeapMemorySegmentPool;
 import org.apache.paimon.memory.MemoryPoolFactory;
 import org.apache.paimon.options.Options;
+import org.apache.paimon.table.BucketMode;
 import org.apache.paimon.table.FileStoreTable;
 import org.apache.paimon.utils.ExecutorThreadFactory;
 import org.slf4j.Logger;
@@ -161,7 +162,7 @@ public void write(InputT event, Context context) throws IOException {
                         .updateBlobWriteContext(((ChangeEvent) event).tableId(), blobWriteContext);
             } catch (Exception e) {
                 // Table might not exist yet, ignore and continue
-                LOGGER.debug("Could not get table for BlobWriteContext: {}", e.getMessage());
+                LOG.debug("Could not get table for BlobWriteContext: {}", e.getMessage());
             }
         }
         if (paimonEvent.getGenericRows() != null) {

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterTest.java

@@ -29,10 +29,8 @@
 import org.apache.flink.cdc.common.types.DataType;
 import org.apache.flink.cdc.common.types.DataTypes;
 import org.apache.flink.cdc.common.types.RowType;
-import org.apache.flink.cdc.connectors.paimon.sink.dlf.DlfCatalogUtil;
 import org.apache.flink.cdc.connectors.paimon.sink.v2.blob.BlobWriteContext;
 import org.apache.flink.cdc.runtime.typeutils.BinaryRecordDataGenerator;
-import org.apache.flink.configuration.Configuration;
 import org.apache.flink.metrics.MetricGroup;
 import org.apache.flink.metrics.groups.UnregisteredMetricsGroup;
 
@@ -78,7 +76,6 @@ class PaimonWriterTest {
     @Mock private CoreOptions mockCoreOptions;
 
     private MockedStatic<FlinkCatalogFactory> mockedFactory;
-    private MockedStatic<DlfCatalogUtil> mockedDlfUtil;
     private MockedStatic<BlobWriteContext> mockedBlobWriteContext;
     private MockedConstruction<StoreSinkWriteImpl> mockedConstruction;
 
@@ -90,17 +87,12 @@ class PaimonWriterTest {
     @BeforeEach
     void setUp() throws Exception {
         mockedFactory = Mockito.mockStatic(FlinkCatalogFactory.class);
-        mockedDlfUtil = Mockito.mockStatic(DlfCatalogUtil.class);
         mockedBlobWriteContext = Mockito.mockStatic(BlobWriteContext.class);
 
         mockedFactory
                 .when(() -> FlinkCatalogFactory.createPaimonCatalog(any(Options.class)))
                 .thenReturn(mockCatalog);
 
-        mockedDlfUtil
-                .when(() -> DlfCatalogUtil.convertOptionToDlf(any(Options.class), any()))
-                .thenCallRealMethod();
-
         BlobWriteContext mockBlobContext = BlobWriteContext.empty();
         mockedBlobWriteContext
                 .when(() -> BlobWriteContext.fromTable(anyBoolean(), any(FileStoreTable.class)))
@@ -127,13 +119,7 @@ void setUp() throws Exception {
                                         .thenReturn(java.util.Collections.emptyList()));
 
         writer =
-                new PaimonWriter<>(
-                        catalogOptions,
-                        metricGroup,
-                        "test_commit_user",
-                        serializer,
-                        new Configuration(),
-                        0L);
+                new PaimonWriter<>(catalogOptions, metricGroup, "test_commit_user", serializer, 0L);
 
         injectMockCatalog(writer, mockCatalog);
     }
@@ -152,9 +138,6 @@ void tearDown() throws Exception {
         if (mockedFactory != null) {
             mockedFactory.close();
         }
-        if (mockedDlfUtil != null) {
-            mockedDlfUtil.close();
-        }
         if (mockedBlobWriteContext != null) {
             mockedBlobWriteContext.close();
         }