From bf38c24adfc52df8db54d4bb45d0e28b39fc588b Mon Sep 17 00:00:00 2001 From: Smith Cruise Date: Fri, 10 Oct 2025 08:40:41 +0800 Subject: [PATCH] [Enhancement] Remove iceberg redundant code (#63860) Signed-off-by: Smith Cruise --- .../connector/iceberg/IcebergCatalogProperties.java | 5 ----- .../com/starrocks/connector/iceberg/IcebergConnector.java | 4 ++-- 2 files changed, 2 insertions(+), 7 deletions(-) diff --git a/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergCatalogProperties.java b/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergCatalogProperties.java index 91edaf5542a..11b6bbbbbdc 100644 --- a/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergCatalogProperties.java +++ b/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergCatalogProperties.java @@ -133,10 +133,6 @@ public class IcebergCatalogProperties { return catalogType; } - public boolean enableIcebergMetadataCache() { - return enableIcebergMetadataCache; - } - public long getIcebergMetaCacheTtlSec() { return icebergMetaCacheTtlSec; } @@ -145,7 +141,6 @@ public class IcebergCatalogProperties { return icebergTableCacheRefreshIntervalSec; } - public int getIcebergJobPlanningThreadNum() { return icebergJobPlanningThreadNum; } diff --git a/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergConnector.java b/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergConnector.java index faab4d89a61..226aa279d5b 100644 --- a/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergConnector.java +++ b/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergConnector.java @@ -111,7 +111,7 @@ public class IcebergConnector implements Connector { if (icebergNativeCatalog == null) { IcebergCatalog nativeCatalog = buildIcebergNativeCatalog(); - if (icebergCatalogProperties.enableIcebergMetadataCache() && !isResourceMappingCatalog(catalogName)) { + if (icebergCatalogProperties.isEnableIcebergMetadataCache() && !isResourceMappingCatalog(catalogName)) { nativeCatalog = new CachingIcebergCatalog(catalogName, nativeCatalog, icebergCatalogProperties, buildBackgroundJobPlanningExecutor()); GlobalStateMgr.getCurrentState().getConnectorTableMetadataProcessor() @@ -161,7 +161,7 @@ public class IcebergConnector implements Connector { @Override public boolean supportMemoryTrack() { - return icebergCatalogProperties.enableIcebergMetadataCache() && icebergNativeCatalog != null; + return icebergCatalogProperties.isEnableIcebergMetadataCache() && icebergNativeCatalog != null; } @Override