Skip to content

ADH-8370: [Backport] Support Zookeeper for metastore service discovery#61

Open
SidorovGreg wants to merge 8 commits into
develop/4.3.0/2.3.10.2from
feature/ADH-8370_2
Open

ADH-8370: [Backport] Support Zookeeper for metastore service discovery#61
SidorovGreg wants to merge 8 commits into
develop/4.3.0/2.3.10.2from
feature/ADH-8370_2

Conversation

@SidorovGreg

Copy link
Copy Markdown

No description provided.

@SidorovGreg SidorovGreg marked this pull request as ready for review June 25, 2026 14:22
Comment thread metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java Outdated
Comment thread common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
Comment thread packaging/docker/docker-compose.yml Outdated
clientConfig.setProperty(ZKClientConfig.ZOOKEEPER_CLIENT_CNXN_SOCKET,
ClientCnxnSocketNetty.class.getName());

ClientX509Util x509Util = new ClientX509Util();

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ClientX509Util is Closeable but never closed, it's used without try-with-resources statement here and in ZooKeeperTokenStore.

} else {
close();
if (isZooKeeperServiceDiscoveryEnabled()) {
resolveMetastoreUris();

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

If there are no live metastore servers registered in ZK then MetaException("No metastore service discovered in ZooKeeper. ...") will be thrown without any retry logic during reconnection process.
I think it's worth adding a retry to get metastore list (add new exception type and check it in RetryingMetaStoreClient::invoke).

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants