diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java index f2b8960b01f4..ffb6f961a052 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java +++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java @@ -274,7 +274,7 @@ public void testMultiTablesCompactionMetrics(@TempDir java.nio.file.Path tempDir throws Exception { Path warehouse = new Path(TraceableFileIO.SCHEME + "://" + tempDir); Options catalogOptions = new Options(); - catalogOptions.set(CatalogOptions.WAREHOUSE, warehouse.getPath()); + catalogOptions.set(CatalogOptions.WAREHOUSE, warehouse.toString()); catalogOptions.set(CatalogOptions.URI, ""); Catalog.Loader catalogLoader = () -> CatalogFactory.createCatalog(CatalogContext.create(catalogOptions));