praveenc7 commented on code in PR #15350:
URL: https://github.com/apache/pinot/pull/15350#discussion_r2117089820
##########
pinot-core/src/main/java/org/apache/pinot/core/data/manager/BaseTableDataManager.java:
##########
@@ -393,6 +393,18 @@ public IndexLoadingConfig fetchIndexLoadingConfig() {
return indexLoadingConfig;
}
+ public void refreshCachedTableSchema() {
+ Schema schema = ZKMetadataProvider.getTableSchema(_propertyStore,
_tableNameWithType);
+ Preconditions.checkState(schema != null, "Failed to find schema for table:
%s", _tableNameWithType);
+ // Update the cached table config and schema with the latest schema
+ TableConfig tableConfig = _cachedTableConfigAndSchema.getLeft();
+ if (tableConfig == null) {
+ tableConfig = ZKMetadataProvider.getTableConfig(_propertyStore,
_tableNameWithType);
+ Preconditions.checkState(tableConfig != null, "Failed to find table
config for table: %s", _tableNameWithType);
+ }
Review Comment:
@Jackie-Jiang added this for refresh
https://github.com/apache/pinot/pull/15956
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
