[rpc] Remove describeLakeStorage to get LakeStorageInfo from table properties

SteNicholas · SteNicholas · commit ef02fbb123b4 · 2025-02-28T09:42:47.000+08:00
diff --git a/fluss-client/src/main/java/com/alibaba/fluss/client/admin/Admin.java b/fluss-client/src/main/java/com/alibaba/fluss/client/admin/Admin.java
@@ -34,7 +34,6 @@
 import com.alibaba.fluss.exception.TableAlreadyExistException;
 import com.alibaba.fluss.exception.TableNotExistException;
 import com.alibaba.fluss.exception.TableNotPartitionedException;
-import com.alibaba.fluss.lakehouse.LakeStorageInfo;
 import com.alibaba.fluss.metadata.DatabaseDescriptor;
 import com.alibaba.fluss.metadata.DatabaseInfo;
 import com.alibaba.fluss.metadata.PartitionInfo;
@@ -325,7 +324,4 @@ ListOffsetsResult listOffsets(
             PhysicalTablePath physicalTablePath,
             Collection<Integer> buckets,
             OffsetSpec offsetSpec);
-
-    /** Describe the lake used for lakehouse storage. */
-    CompletableFuture<LakeStorageInfo> describeLakeStorage();
 }
diff --git a/fluss-client/src/main/java/com/alibaba/fluss/client/admin/FlussAdmin.java b/fluss-client/src/main/java/com/alibaba/fluss/client/admin/FlussAdmin.java
@@ -23,7 +23,6 @@
 import com.alibaba.fluss.client.utils.ClientRpcMessageUtils;
 import com.alibaba.fluss.cluster.Cluster;
 import com.alibaba.fluss.cluster.ServerNode;
-import com.alibaba.fluss.lakehouse.LakeStorageInfo;
 import com.alibaba.fluss.metadata.DatabaseDescriptor;
 import com.alibaba.fluss.metadata.DatabaseInfo;
 import com.alibaba.fluss.metadata.PartitionInfo;
@@ -42,7 +41,6 @@
 import com.alibaba.fluss.rpc.messages.CreateTableRequest;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsRequest;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsResponse;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageRequest;
 import com.alibaba.fluss.rpc.messages.DropDatabaseRequest;
 import com.alibaba.fluss.rpc.messages.DropTableRequest;
 import com.alibaba.fluss.rpc.messages.GetDatabaseInfoRequest;
@@ -341,12 +339,6 @@ public ListOffsetsResult listOffsets(
         return new ListOffsetsResult(bucketToOffsetMap);
     }
 
-    @Override
-    public CompletableFuture<LakeStorageInfo> describeLakeStorage() {
-        return gateway.describeLakeStorage(new DescribeLakeStorageRequest())
-                .thenApply(ClientRpcMessageUtils::toLakeStorageInfo);
-    }
-
     @Override
     public void close() {
         // nothing to do yet
diff --git a/fluss-client/src/main/java/com/alibaba/fluss/client/utils/ClientRpcMessageUtils.java b/fluss-client/src/main/java/com/alibaba/fluss/client/utils/ClientRpcMessageUtils.java
@@ -37,7 +37,6 @@
 import com.alibaba.fluss.remote.RemoteLogFetchInfo;
 import com.alibaba.fluss.remote.RemoteLogSegment;
 import com.alibaba.fluss.rpc.entity.FetchLogResultForBucket;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageResponse;
 import com.alibaba.fluss.rpc.messages.GetFileSystemSecurityTokenResponse;
 import com.alibaba.fluss.rpc.messages.GetKvSnapshotMetadataResponse;
 import com.alibaba.fluss.rpc.messages.GetLatestKvSnapshotsResponse;
@@ -387,10 +386,6 @@ public static List<PartitionInfo> toPartitionInfos(ListPartitionInfosResponse re
                 .collect(Collectors.toList());
     }
 
-    public static LakeStorageInfo toLakeStorageInfo(DescribeLakeStorageResponse response) {
-        return toLakeStorageInfo(response.getLakehouseStorageInfo());
-    }
-
     private static LakeStorageInfo toLakeStorageInfo(PbLakeStorageInfo pbLakeStorageInfo) {
         Map<String, String> dataLakeCatalogConfig =
                 toKeyValueMap(pbLakeStorageInfo.getCatalogPropertiesList());
diff --git a/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/catalog/FlinkCatalog.java b/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/catalog/FlinkCatalog.java
@@ -24,6 +24,7 @@
 import com.alibaba.fluss.connector.flink.lakehouse.LakeCatalog;
 import com.alibaba.fluss.connector.flink.utils.CatalogExceptionUtils;
 import com.alibaba.fluss.connector.flink.utils.FlinkConversions;
+import com.alibaba.fluss.connector.flink.utils.LakeStorageInfoUtils;
 import com.alibaba.fluss.exception.FlussRuntimeException;
 import com.alibaba.fluss.metadata.DatabaseDescriptor;
 import com.alibaba.fluss.metadata.TableDescriptor;
@@ -262,7 +263,7 @@ public CatalogBaseTable getTable(ObjectPath objectPath)
                                             objectPath.getDatabaseName(),
                                             tableName.split("\\" + LAKE_TABLE_SPLITTER)[0])));
                 }
-                return getLakeTable(objectPath.getDatabaseName(), tableName);
+                return getLakeTable(objectPath.getDatabaseName(), tableName, tableInfo);
             } else {
                 tableInfo = admin.getTableInfo(tablePath).get();
             }
@@ -284,9 +285,10 @@ public CatalogBaseTable getTable(ObjectPath objectPath)
         }
     }
 
-    protected CatalogBaseTable getLakeTable(String databaseName, String tableName)
+    protected CatalogBaseTable getLakeTable(
+            String databaseName, String tableName, TableInfo tableInfo)
             throws TableNotExistException, CatalogException {
-        mayInitLakeCatalogCatalog();
+        mayInitLakeCatalogCatalog(tableInfo);
         String[] tableComponents = tableName.split("\\" + LAKE_TABLE_SPLITTER);
         if (tableComponents.length == 1) {
             // should be pattern like table_name$lake
@@ -530,13 +532,14 @@ protected TablePath toTablePath(ObjectPath objectPath) {
         return TablePath.of(objectPath.getDatabaseName(), objectPath.getObjectName());
     }
 
-    private void mayInitLakeCatalogCatalog() {
+    private void mayInitLakeCatalogCatalog(TableInfo tableInfo) {
         if (lakeCatalog == null) {
             synchronized (this) {
                 if (lakeCatalog == null) {
                     try {
                         Map<String, String> catalogProperties =
-                                admin.describeLakeStorage().get().getCatalogProperties();
+                                LakeStorageInfoUtils.getLakeStorageInfo(tableInfo)
+                                        .getCatalogProperties();
                         lakeCatalog = new LakeCatalog(catalogName, catalogProperties, classLoader);
                     } catch (Exception e) {
                         throw new FlussRuntimeException("Failed to init paimon catalog.", e);
diff --git a/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/lakehouse/LakeSplitReaderGenerator.java b/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/lakehouse/LakeSplitReaderGenerator.java
@@ -17,15 +17,14 @@
 package com.alibaba.fluss.connector.flink.lakehouse;
 
 import com.alibaba.fluss.client.Connection;
-import com.alibaba.fluss.client.admin.Admin;
 import com.alibaba.fluss.client.table.Table;
 import com.alibaba.fluss.connector.flink.lakehouse.paimon.reader.PaimonSnapshotAndLogSplitScanner;
 import com.alibaba.fluss.connector.flink.lakehouse.paimon.reader.PaimonSnapshotScanner;
 import com.alibaba.fluss.connector.flink.lakehouse.paimon.split.PaimonSnapshotAndFlussLogSplit;
 import com.alibaba.fluss.connector.flink.lakehouse.paimon.split.PaimonSnapshotSplit;
 import com.alibaba.fluss.connector.flink.source.reader.BoundedSplitReader;
 import com.alibaba.fluss.connector.flink.source.split.SourceSplitBase;
-import com.alibaba.fluss.lakehouse.LakeStorageInfo;
+import com.alibaba.fluss.connector.flink.utils.LakeStorageInfoUtils;
 import com.alibaba.fluss.metadata.TablePath;
 
 import org.apache.flink.util.ExceptionUtils;
@@ -120,18 +119,16 @@ private FileStoreTable getFileStoreTable() {
             return fileStoreTable;
         }
 
-        try (Admin admin = connection.getAdmin()) {
-            LakeStorageInfo dataLakeInfo = admin.describeLakeStorage().get();
-            try (Catalog paimonCatalog =
-                    FlinkCatalogFactory.createPaimonCatalog(
-                            Options.fromMap(dataLakeInfo.getCatalogProperties()))) {
-                fileStoreTable =
-                        (FileStoreTable)
-                                paimonCatalog.getTable(
-                                        Identifier.create(
-                                                tablePath.getDatabaseName(),
-                                                tablePath.getTableName()));
-            }
+        try (Catalog paimonCatalog =
+                FlinkCatalogFactory.createPaimonCatalog(
+                        Options.fromMap(
+                                LakeStorageInfoUtils.getLakeStorageInfo(table.getTableInfo())
+                                        .getCatalogProperties()))) {
+            fileStoreTable =
+                    (FileStoreTable)
+                            paimonCatalog.getTable(
+                                    Identifier.create(
+                                            tablePath.getDatabaseName(), tablePath.getTableName()));
             return fileStoreTable;
         } catch (Exception e) {
             throw new FlinkRuntimeException(
diff --git a/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/utils/LakeStorageInfoUtils.java b/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/utils/LakeStorageInfoUtils.java
@@ -0,0 +1,63 @@
+/*
+ * Copyright (c) 2024 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.alibaba.fluss.connector.flink.utils;
+
+import com.alibaba.fluss.config.ConfigOptions;
+import com.alibaba.fluss.lakehouse.LakeStorageInfo;
+import com.alibaba.fluss.metadata.DataLakeFormat;
+import com.alibaba.fluss.metadata.TableInfo;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/** Utility class for {@link LakeStorageInfo}. */
+public class LakeStorageInfoUtils {
+
+    private static final String TABLE_DATALAKE_PAIMON_PREFIX = "table.datalake.paimon.";
+
+    public static LakeStorageInfo getLakeStorageInfo(TableInfo tableInfo) {
+        DataLakeFormat datalakeFormat =
+                tableInfo.getProperties().get(ConfigOptions.TABLE_DATALAKE_FORMAT);
+        if (datalakeFormat == null) {
+            throw new IllegalArgumentException(
+                    String.format(
+                            "The lakehouse storage is not set, please set it by %s",
+                            ConfigOptions.TABLE_DATALAKE_FORMAT.key()));
+        }
+
+        if (datalakeFormat != DataLakeFormat.PAIMON) {
+            throw new UnsupportedOperationException(
+                    String.format(
+                            "The lakehouse storage %s "
+                                    + " is not supported. Only %s is supported.",
+                            datalakeFormat, DataLakeFormat.PAIMON));
+        }
+
+        // currently, extract catalog config
+        Map<String, String> datalakeConfig = new HashMap<>();
+        Map<String, String> flussConfig = tableInfo.getCustomProperties().toMap();
+        for (Map.Entry<String, String> configEntry : flussConfig.entrySet()) {
+            String configKey = configEntry.getKey();
+            String configValue = configEntry.getValue();
+            if (configKey.startsWith(TABLE_DATALAKE_PAIMON_PREFIX)) {
+                datalakeConfig.put(
+                        configKey.substring(TABLE_DATALAKE_PAIMON_PREFIX.length()), configValue);
+            }
+        }
+        return new LakeStorageInfo(datalakeFormat.toString(), datalakeConfig);
+    }
+}
diff --git a/fluss-lakehouse/fluss-lakehouse-paimon/src/test/java/com/alibaba/fluss/lakehouse/paimon/testutils/FlinkPaimonTestBase.java b/fluss-lakehouse/fluss-lakehouse-paimon/src/test/java/com/alibaba/fluss/lakehouse/paimon/testutils/FlinkPaimonTestBase.java
@@ -66,7 +66,7 @@ public class FlinkPaimonTestBase {
     protected static Connection conn;
     protected static Admin admin;
     protected static Configuration clientConf;
-    private static String warehousePath;
+    protected static String warehousePath;
 
     private static Configuration initConfig() {
         Configuration conf = new Configuration();
diff --git a/fluss-lakehouse/fluss-lakehouse-paimon/src/test/java/com/alibaba/fluss/lakehouse/paimon/testutils/PaimonSyncTestBase.java b/fluss-lakehouse/fluss-lakehouse-paimon/src/test/java/com/alibaba/fluss/lakehouse/paimon/testutils/PaimonSyncTestBase.java
@@ -23,6 +23,7 @@
 import com.alibaba.fluss.lakehouse.paimon.sink.NewTablesAddedPaimonListener;
 import com.alibaba.fluss.lakehouse.paimon.sink.PaimonDataBaseSyncSinkBuilder;
 import com.alibaba.fluss.lakehouse.paimon.source.FlussDatabaseSyncSource;
+import com.alibaba.fluss.metadata.DataLakeFormat;
 import com.alibaba.fluss.metadata.Schema;
 import com.alibaba.fluss.metadata.TableBucket;
 import com.alibaba.fluss.metadata.TableDescriptor;
@@ -122,7 +123,10 @@ protected long createLogTable(TablePath tablePath, int bucketNum, boolean isPart
         TableDescriptor.Builder tableBuilder =
                 TableDescriptor.builder()
                         .distributedBy(bucketNum, "a")
-                        .property(ConfigOptions.TABLE_DATALAKE_ENABLED.key(), "true");
+                        .property(ConfigOptions.TABLE_DATALAKE_ENABLED.key(), "true")
+                        .property(ConfigOptions.TABLE_DATALAKE_FORMAT, DataLakeFormat.PAIMON)
+                        .customProperty("table.datalake.paimon.metastore", "filesystem")
+                        .customProperty("table.datalake.paimon.warehouse", warehousePath);
 
         if (isPartitioned) {
             schemaBuilder.column("c", DataTypes.STRING());
@@ -150,6 +154,9 @@ protected long createPkTable(TablePath tablePath, int bucketNum) throws Exceptio
                                         .build())
                         .distributedBy(bucketNum)
                         .property(ConfigOptions.TABLE_DATALAKE_ENABLED.key(), "true")
+                        .property(ConfigOptions.TABLE_DATALAKE_FORMAT, DataLakeFormat.PAIMON)
+                        .customProperty("table.datalake.paimon.metastore", "filesystem")
+                        .customProperty("table.datalake.paimon.warehouse", warehousePath)
                         .build();
         return createTable(tablePath, table1Descriptor);
     }
diff --git a/fluss-rpc/src/main/java/com/alibaba/fluss/rpc/gateway/AdminReadOnlyGateway.java b/fluss-rpc/src/main/java/com/alibaba/fluss/rpc/gateway/AdminReadOnlyGateway.java
@@ -19,8 +19,6 @@
 import com.alibaba.fluss.rpc.RpcGateway;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsRequest;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsResponse;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageRequest;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageResponse;
 import com.alibaba.fluss.rpc.messages.GetDatabaseInfoRequest;
 import com.alibaba.fluss.rpc.messages.GetDatabaseInfoResponse;
 import com.alibaba.fluss.rpc.messages.GetFileSystemSecurityTokenRequest;
@@ -179,15 +177,6 @@ CompletableFuture<GetFileSystemSecurityTokenResponse> getFileSystemSecurityToken
     CompletableFuture<ListPartitionInfosResponse> listPartitionInfos(
             ListPartitionInfosRequest request);
 
-    /**
-     * Describe the lake storage used for Fluss.
-     *
-     * @return a future returns lake storage info
-     */
-    @RPC(api = ApiKeys.DESCRIBE_LAKE_STORAGE)
-    CompletableFuture<DescribeLakeStorageResponse> describeLakeStorage(
-            DescribeLakeStorageRequest request);
-
     /**
      * Get the latest lake snapshot for the given table.
      *
diff --git a/fluss-rpc/src/main/java/com/alibaba/fluss/rpc/protocol/ApiKeys.java b/fluss-rpc/src/main/java/com/alibaba/fluss/rpc/protocol/ApiKeys.java
@@ -59,7 +59,6 @@ public enum ApiKeys {
     NOTIFY_KV_SNAPSHOT_OFFSET(1029, 0, 0, PRIVATE),
     COMMIT_LAKE_TABLE_SNAPSHOT(1030, 0, 0, PRIVATE),
     NOTIFY_LAKE_TABLE_OFFSET(1031, 0, 0, PRIVATE),
-    DESCRIBE_LAKE_STORAGE(1032, 0, 0, PUBLIC),
     GET_LATEST_LAKE_SNAPSHOT(1033, 0, 0, PUBLIC),
     LIMIT_SCAN(1034, 0, 0, PUBLIC),
     PREFIX_LOOKUP(1035, 0, 0, PUBLIC),
diff --git a/fluss-rpc/src/main/proto/FlussApi.proto b/fluss-rpc/src/main/proto/FlussApi.proto
@@ -359,13 +359,6 @@ message GetFileSystemSecurityTokenResponse {
   repeated PbKeyValue addition_info = 4;
 }
 
-message DescribeLakeStorageRequest {
-}
-
-message DescribeLakeStorageResponse {
-  required PbLakeStorageInfo lakehouse_storage_info = 1;
-}
-
 // init writer request and response
 message InitWriterRequest {
 }
diff --git a/fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java b/fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java
@@ -46,8 +46,6 @@
 import com.alibaba.fluss.rpc.messages.ApiVersionsResponse;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsRequest;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsResponse;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageRequest;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageResponse;
 import com.alibaba.fluss.rpc.messages.GetDatabaseInfoRequest;
 import com.alibaba.fluss.rpc.messages.GetDatabaseInfoResponse;
 import com.alibaba.fluss.rpc.messages.GetFileSystemSecurityTokenRequest;
@@ -413,17 +411,6 @@ public CompletableFuture<ListPartitionInfosResponse> listPartitionInfos(
                 RpcMessageUtils.toListPartitionInfosResponse(partitionNameAndIds));
     }
 
-    @Override
-    public CompletableFuture<DescribeLakeStorageResponse> describeLakeStorage(
-            DescribeLakeStorageRequest request) {
-        if (lakeStorageInfo == null) {
-            throw new LakeStorageNotConfiguredException("Lake storage is not configured.");
-        }
-
-        return CompletableFuture.completedFuture(
-                RpcMessageUtils.makeDescribeLakeStorageResponse(lakeStorageInfo));
-    }
-
     @Override
     public CompletableFuture<GetLatestLakeSnapshotResponse> getLatestLakeSnapshot(
             GetLatestLakeSnapshotRequest request) {
diff --git a/fluss-server/src/main/java/com/alibaba/fluss/server/utils/RpcMessageUtils.java b/fluss-server/src/main/java/com/alibaba/fluss/server/utils/RpcMessageUtils.java
@@ -46,7 +46,6 @@
 import com.alibaba.fluss.rpc.messages.CommitKvSnapshotRequest;
 import com.alibaba.fluss.rpc.messages.CommitLakeTableSnapshotRequest;
 import com.alibaba.fluss.rpc.messages.CommitRemoteLogManifestRequest;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageResponse;
 import com.alibaba.fluss.rpc.messages.FetchLogRequest;
 import com.alibaba.fluss.rpc.messages.FetchLogResponse;
 import com.alibaba.fluss.rpc.messages.GetFileSystemSecurityTokenResponse;
@@ -1227,13 +1226,6 @@ public static NotifyLakeTableOffsetData getNotifyLakeTableOffset(
                 notifyLakeTableOffsetRequest.getCoordinatorEpoch(), lakeBucketOffsetMap);
     }
 
-    public static DescribeLakeStorageResponse makeDescribeLakeStorageResponse(
-            LakeStorageInfo lakeStorageInfo) {
-        DescribeLakeStorageResponse describeLakeStorageResponse = new DescribeLakeStorageResponse();
-        describeLakeStorageResponse.setLakehouseStorageInfo(toPbLakeStorageInfo(lakeStorageInfo));
-        return describeLakeStorageResponse;
-    }
-
     public static GetLatestLakeSnapshotResponse makeGetLatestLakeSnapshotResponse(
             long tableId, LakeStorageInfo lakeStorageInfo, LakeTableSnapshot lakeTableSnapshot) {
         GetLatestLakeSnapshotResponse getLakeTableSnapshotResponse =
diff --git a/fluss-server/src/test/java/com/alibaba/fluss/server/coordinator/TestCoordinatorGateway.java b/fluss-server/src/test/java/com/alibaba/fluss/server/coordinator/TestCoordinatorGateway.java
@@ -34,8 +34,6 @@
 import com.alibaba.fluss.rpc.messages.CreateTableResponse;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsRequest;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsResponse;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageRequest;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageResponse;
 import com.alibaba.fluss.rpc.messages.DropDatabaseRequest;
 import com.alibaba.fluss.rpc.messages.DropDatabaseResponse;
 import com.alibaba.fluss.rpc.messages.DropTableRequest;
@@ -124,12 +122,6 @@ public CompletableFuture<DropTableResponse> dropTable(DropTableRequest request)
         throw new UnsupportedOperationException();
     }
 
-    @Override
-    public CompletableFuture<DescribeLakeStorageResponse> describeLakeStorage(
-            DescribeLakeStorageRequest request) {
-        throw new UnsupportedOperationException();
-    }
-
     @Override
     public CompletableFuture<GetLatestLakeSnapshotResponse> getLatestLakeSnapshot(
             GetLatestLakeSnapshotRequest request) {
diff --git a/fluss-server/src/test/java/com/alibaba/fluss/server/tablet/TestTabletServerGateway.java b/fluss-server/src/test/java/com/alibaba/fluss/server/tablet/TestTabletServerGateway.java
@@ -25,8 +25,6 @@
 import com.alibaba.fluss.rpc.messages.ApiVersionsResponse;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsRequest;
 import com.alibaba.fluss.rpc.messages.DatabaseExistsResponse;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageRequest;
-import com.alibaba.fluss.rpc.messages.DescribeLakeStorageResponse;
 import com.alibaba.fluss.rpc.messages.FetchLogRequest;
 import com.alibaba.fluss.rpc.messages.FetchLogResponse;
 import com.alibaba.fluss.rpc.messages.GetDatabaseInfoRequest;
@@ -146,12 +144,6 @@ public CompletableFuture<ListPartitionInfosResponse> listPartitionInfos(
         throw new UnsupportedOperationException();
     }
 
-    @Override
-    public CompletableFuture<DescribeLakeStorageResponse> describeLakeStorage(
-            DescribeLakeStorageRequest request) {
-        throw new UnsupportedOperationException();
-    }
-
     @Override
     public CompletableFuture<GetLatestLakeSnapshotResponse> getLatestLakeSnapshot(
             GetLatestLakeSnapshotRequest request) {
