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/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 763f46983 [core] Remove useless fs.allow-hadoop-fallback in catalog 
options
763f46983 is described below

commit 763f46983c66d0edfc62cc23c093eced04cafdce
Author: Jingsong <[email protected]>
AuthorDate: Wed Sep 25 10:46:24 2024 +0800

    [core] Remove useless fs.allow-hadoop-fallback in catalog options
---
 docs/layouts/shortcodes/generated/catalog_configuration.html       | 6 ------
 .../src/main/java/org/apache/paimon/options/CatalogOptions.java    | 7 -------
 .../test/java/org/apache/paimon/flink/FileSystemCatalogITCase.java | 3 ---
 3 files changed, 16 deletions(-)

diff --git a/docs/layouts/shortcodes/generated/catalog_configuration.html 
b/docs/layouts/shortcodes/generated/catalog_configuration.html
index 7c13f1c99..b9d74c812 100644
--- a/docs/layouts/shortcodes/generated/catalog_configuration.html
+++ b/docs/layouts/shortcodes/generated/catalog_configuration.html
@@ -68,12 +68,6 @@ under the License.
             <td>Integer</td>
             <td>Configure the size of the connection pool.</td>
         </tr>
-        <tr>
-            <td><h5>fs.allow-hadoop-fallback</h5></td>
-            <td style="word-wrap: break-word;">true</td>
-            <td>Boolean</td>
-            <td>Allow to fallback to hadoop File IO when no file io found for 
the scheme.</td>
-        </tr>
         <tr>
             <td><h5>lineage-meta</h5></td>
             <td style="word-wrap: break-word;">(none)</td>
diff --git 
a/paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java 
b/paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java
index 55dda70ca..081668675 100644
--- a/paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java
+++ b/paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java
@@ -78,13 +78,6 @@ public class CatalogOptions {
                     .defaultValue(Duration.ofMinutes(8))
                     .withDescription("The maximum time to wait for acquiring 
the lock.");
 
-    public static final ConfigOption<Boolean> FS_ALLOW_HADOOP_FALLBACK =
-            key("fs.allow-hadoop-fallback")
-                    .booleanType()
-                    .defaultValue(true)
-                    .withDescription(
-                            "Allow to fallback to hadoop File IO when no file 
io found for the scheme.");
-
     public static final ConfigOption<Integer> CLIENT_POOL_SIZE =
             key("client-pool-size")
                     .intType()
diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileSystemCatalogITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileSystemCatalogITCase.java
index 4e1ea424f..239043ff7 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileSystemCatalogITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileSystemCatalogITCase.java
@@ -117,7 +117,6 @@ public class FileSystemCatalogITCase extends 
AbstractTestBase {
                                 + "'table-default.opt1'='value1', "
                                 + "'table-default.opt2'='value2', "
                                 + "'table-default.opt3'='value3', "
-                                + "'fs.allow-hadoop-fallback'='false',"
                                 + "'lock.enabled'='false'"
                                 + ")",
                         path));
@@ -134,7 +133,6 @@ public class FileSystemCatalogITCase extends 
AbstractTestBase {
         assertThat(tableOptions).containsEntry("opt1", "value1");
         assertThat(tableOptions).containsEntry("opt2", "value2");
         assertThat(tableOptions).containsEntry("opt3", "value3");
-        assertThat(tableOptions).doesNotContainKey("fs.allow-hadoop-fallback");
         assertThat(tableOptions).doesNotContainKey("lock.enabled");
 
         // check table options override catalog's
@@ -147,7 +145,6 @@ public class FileSystemCatalogITCase extends 
AbstractTestBase {
         assertThat(tableOptions).containsEntry("opt1", "value1");
         assertThat(tableOptions).containsEntry("opt2", "value2");
         assertThat(tableOptions).containsEntry("opt3", "value4");
-        assertThat(tableOptions).doesNotContainKey("fs.allow-hadoop-fallback");
         assertThat(tableOptions).doesNotContainKey("lock.enabled");
     }
 

Reply via email to