This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new cc6aa1daa [test] fix variable warehouse of type 
org.apache.paimon.fs.Path (#2386)
cc6aa1daa is described below

commit cc6aa1daa9dea94eba75c8aa943367464e456b62
Author: Kerwin <[email protected]>
AuthorDate: Fri Nov 24 14:14:58 2023 +0800

    [test] fix variable warehouse of type org.apache.paimon.fs.Path (#2386)
---
 .../src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 f2b8960b0..ffb6f961a 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 class CompactorSinkITCase extends AbstractTestBase {
             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));

Reply via email to