[core] Remove useless fs.allow-hadoop-fallback in catalog options

apache · Sep 25, 2024 · 763f469 · 763f469
1 parent cba8447
commit 763f469
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 16 deletions.
diff --git a/docs/layouts/shortcodes/generated/catalog_configuration.html b/docs/layouts/shortcodes/generated/catalog_configuration.html
@@ -68,12 +68,6 @@
  <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
@@ -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/...nk/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileSystemCatalogITCase.java b/...nk/paimon-flink-common/src/test/java/org/apache/paimon/flink/FileSystemCatalogITCase.java
@@ -117,7 +117,6 @@ public void testCatalogOptionsInheritAndOverride() throws Exception {
  + "'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 void testCatalogOptionsInheritAndOverride() throws Exception {
  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 void testCatalogOptionsInheritAndOverride() throws Exception {
  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");
  }