hubgeter commented on code in PR #39239:
URL: https://github.com/apache/doris/pull/39239#discussion_r1720790740
##########
fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/MetastoreEventsProcessor.java:
##########
@@ -125,6 +128,8 @@ private void realRun() {
} catch (MetastoreNotificationFetchException e) {
LOG.warn("Failed to fetch hms events on {}. msg: ",
hmsExternalCatalog.getName(), e);
} catch (Exception ex) {
+ hmsExternalCatalog.onRefresh(true);
Review Comment:
Suppose you receive a set of events, and when processing the insert event,
the initialization reports a nullpointer. The event processing fails, and our
data with Hive is out of sync? Refresh it and you can process other events next
time. i will modify it to `onRefreshCache`
--
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: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
