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();

Reply via email to