commit c9d16d78eb733a8c603ad88a4fd5001edef60ac7 Author: Vihang Karajgaonkar Date: Thu Feb 23 10:26:38 2017 -0800 HIVE-16014 : HiveMetastoreChecker should use hive.metastore.fshandler.threads instead of hive.mv.files.thread for pool size diff --git a/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java b/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java index 7c94c95f00492467ba27dedc9ce513e13c85ea61..c0d8dc1b608876062508fc2d477a7a701f99233c 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java @@ -408,7 +408,7 @@ private void checkPartitionDirs(Path basePath, Set allDirs, int maxDepth) Set dirSet = Collections.newSetFromMap(new ConcurrentHashMap()); // Here we just reuse the THREAD_COUNT configuration for // HIVE_MOVE_FILES_THREAD_COUNT - int poolSize = conf.getInt(ConfVars.HIVE_MOVE_FILES_THREAD_COUNT.varname, 15); + int poolSize = conf.getInt(ConfVars.METASTORE_FS_HANDLER_THREADS_COUNT.varname, 15); // Check if too low config is provided for move files. 2x CPU is reasonable max count. poolSize = poolSize == 0 ? poolSize : Math.max(poolSize,