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 cc45aa2b741d..5bfc98879cca 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 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();