This is an automated email from the ASF dual-hosted git repository.
soumyakanti3578 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push:
new b8dd76c4511 HIVE-30139: Auto partition discovery feature logging null
as table name in case of any exception (#6854)
b8dd76c4511 is described below
commit b8dd76c4511bf7219728ae5a0b4e47ee883ec4ec
Author: Dayakar M <[email protected]>
AuthorDate: Mon Oct 12 22:50:23 2026 +0530
HIVE-30139: Auto partition discovery feature logging null as table name in
case of any exception (#6854)
---
.../org/apache/hadoop/hive/metastore/PartitionManagementTask.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/PartitionManagementTask.java
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/PartitionManagementTask.java
index cc45aa2b741..5bfc98879cc 100644
---
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/PartitionManagementTask.java
+++
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/PartitionManagementTask.java
@@ -84,7 +84,6 @@ private static boolean partitionDiscoveryEnabled(Map<String,
String> params) {
@Override
public void run() {
if (lock.tryLock()) {
- String qualifiedTableName = null;
IMetaStoreClient msc = null;
try {
msc = new HiveMetaStoreClient(conf);
@@ -120,12 +119,12 @@ public void run() {
// this always runs in 'sync' mode where partitions can be added and
dropped
MsckInfo msckInfo = new MsckInfo(table.getCat(), table.getDb(),
table.getTable(),
null, null, true, true, true, -1);
- executorService.submit(new MsckThread(msckInfo, msckConf,
qualifiedTableName, countDownLatch));
+ executorService.submit(new MsckThread(msckInfo, msckConf,
table.toString(), countDownLatch));
}
countDownLatch.await();
executorService.shutdownNow();
} catch (Exception e) {
- LOG.error("Exception while running partition discovery task for table:
" + qualifiedTableName, e);
+ LOG.error("Exception while running partition discovery task", e);
} finally {
if (msc != null) {
msc.close();