From 0c2ff09fcfa6f4be3b052e8c330963e621d3c15f Mon Sep 17 00:00:00 2001 From: Xiangyu Wang Date: Thu, 30 Mar 2023 23:09:07 +0800 Subject: [PATCH] [Fix](multi-catalog) fix hms automatic update error. (#18252) Co-authored-by: wangxiangyu@360shuke.com --- .../java/org/apache/doris/datasource/HMSExternalCatalog.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/HMSExternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/HMSExternalCatalog.java index 319227495b..f84ea8b9f6 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/HMSExternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/HMSExternalCatalog.java @@ -54,7 +54,9 @@ public class HMSExternalCatalog extends ExternalCatalog { private static final int MAX_CLIENT_POOL_SIZE = 8; protected PooledHiveMetaStoreClient client; // Record the latest synced event id when processing hive events - private long lastSyncedEventId; + // Must set to -1 otherwise client.getNextNotification will throw exception + // Reference to https://github.com/apache/doris/issues/18251 + private long lastSyncedEventId = -1L; public static final String ENABLE_SELF_SPLITTER = "enable.self.splitter"; public static final String FILE_META_CACHE_TTL_SECOND = "file.meta.cache.ttl-second";