diff --git a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 269798c702..e1346de8bc 100644 --- a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -241,6 +241,8 @@ public TTransport getTransport(TTransport trans) { private final Configuration conf; // stores datastore (jpox) properties, // right now they come from jpox.properties + private final static AtomicBoolean initialized = new AtomicBoolean(false); + private static String currentUrl; private FileMetadataManager fileMetadataManager; private PartitionExpressionProxy expressionProxy; @@ -558,19 +560,21 @@ public void init() throws MetaException { partitionValidationPattern = null; } - ThreadPool.initialize(conf); - Collection taskNames = - MetastoreConf.getStringCollection(conf, ConfVars.TASK_THREADS_ALWAYS); - for (String taskName : taskNames) { - MetastoreTaskThread task = - JavaUtils.newInstance(JavaUtils.getClass(taskName, MetastoreTaskThread.class)); - task.setConf(conf); - long freq = task.runFrequency(TimeUnit.MILLISECONDS); - // For backwards compatibility, since some threads used to be hard coded but only run if - // frequency was > 0 - if (freq > 0) { - ThreadPool.getPool().scheduleAtFixedRate(task, freq, freq, TimeUnit.MILLISECONDS); - + // We only initialize the tasks that need to be run periodically once + if (initialized.compareAndSet(false, true)) { + ThreadPool.initialize(conf); + Collection taskNames = + MetastoreConf.getStringCollection(conf, ConfVars.TASK_THREADS_ALWAYS); + for (String taskName : taskNames) { + MetastoreTaskThread task = + JavaUtils.newInstance(JavaUtils.getClass(taskName, MetastoreTaskThread.class)); + task.setConf(conf); + long freq = task.runFrequency(TimeUnit.MILLISECONDS); + // For backwards compatibility, since some threads used to be hard coded but only run if + // frequency was > 0 + if (freq > 0) { + ThreadPool.getPool().scheduleAtFixedRate(task, freq, freq, TimeUnit.MILLISECONDS); + } } } expressionProxy = PartFilterExprUtil.createExpressionProxy(conf);