tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Enhancement] Remove iceberg redundant code (#63860) 

Signed-off-by: Smith Cruise <chendingchao1@126.com>
This commit is contained in:
Smith Cruise 2025-10-10 08:40:41 +08:00 committed by GitHub
parent 7ed48a790a
commit bf38c24adf
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergCatalogProperties.java
View File

@ -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;
}

4
fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergConnector.java
View File

@ -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