zhangstar333 commented on code in PR #58997:
URL: https://github.com/apache/doris/pull/58997#discussion_r2613239704
##########
fe/fe-core/src/main/java/org/apache/doris/catalog/RefreshManager.java:
##########
@@ -300,20 +302,29 @@ public void run() {
CatalogIf catalog =
Env.getCurrentEnv().getCatalogMgr().getCatalog(catalogId);
if (catalog != null) {
String catalogName = catalog.getName();
+ LOG.info("Scheduled refresh triggered for catalog {}
(id={}), interval={}s, invalidCache=true",
+ catalogName, catalogId, original);
/**
* Now do not invoke
* {@link
org.apache.doris.analysis.RefreshCatalogStmt#analyze(Analyzer)} is ok,
* because the default value of invalidCache is true.
* */
try {
Env.getCurrentEnv().getRefreshManager().handleRefreshCatalog(catalogName, true);
+ LOG.info("Scheduled refresh completed for catalog
{} (id={}), next refresh in {}s",
+ catalogName, catalogId, original);
} catch (Exception e) {
- LOG.warn("failed to refresh catalog {}",
catalogName, e);
+ LOG.warn("Failed to execute scheduled refresh for
catalog {} (id={})",
+ catalogName, catalogId, e);
}
// reset
timeGroup[1] = original;
refreshMap.put(catalogId, timeGroup);
+ } else {
+ LOG.warn("Scheduled refresh skipped: catalog id={} not
found, removing from refresh map",
+ catalogId);
Review Comment:
here could add catalogName also
--
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]
