This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 0c2ff09fcf [Fix](multi-catalog) fix hms automatic update error.
(#18252)
0c2ff09fcf is described below
commit 0c2ff09fcfa6f4be3b052e8c330963e621d3c15f
Author: Xiangyu Wang <dut.xian...@gmail.com>
AuthorDate: Thu Mar 30 23:09:07 2023 +0800
[Fix](multi-catalog) fix hms automatic update error. (#18252)
Co-authored-by: wangxian...@360shuke.com <wangxian...@360shuke.com>
---
.../src/main/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";
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
