Revert "[improve][offload] Use filesystemURI as the storage path (#23591

)" This reverts commit c1cc2d6. This change is reverted in branch-3.0 since #23591 was needed due to #23411 which is not included in branch-3.0.
apache · Nov 22, 2024 · bb909e6 · bb909e6
1 parent f68f282
commit bb909e6
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 168 deletions.
diff --git a/...g/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java b/...g/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java
@@ -105,7 +105,7 @@ private FileSystemManagedLedgerOffloader(OffloadPoliciesImpl conf, OrderedSchedu
 
         this.configuration.setClassLoader(FileSystemLedgerOffloaderFactory.class.getClassLoader());
         this.driverName = conf.getManagedLedgerOffloadDriver();
-        this.storageBasePath = configuration.get("fs.defaultFS");
+        this.storageBasePath = configuration.get("hadoop.tmp.dir");
         this.scheduler = scheduler;
         this.fileSystem = FileSystem.get(configuration);
         this.assignmentScheduler = OrderedScheduler.newSchedulerBuilder()

diff --git a/...g/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemOffloaderLocalFileTest.java b/...g/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemOffloaderLocalFileTest.java
diff --git a/tiered-storage/file-system/src/test/resources/filesystem_offload_core_site.xml b/tiered-storage/file-system/src/test/resources/filesystem_offload_core_site.xml