diff --git a/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java b/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java index da46854..de6adb5 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java @@ -1864,7 +1864,7 @@ public Void call() throws Exception { for (Partition p : partitionsMap.values()) { partNames.add(p.getName()); } - metaStoreClient.addDynamicPartitions(txnId, tbl.getDbName(), tbl.getTableName(), + getMSC().addDynamicPartitions(txnId, tbl.getDbName(), tbl.getTableName(), partNames, AcidUtils.toDataOperationType(operation)); } LOG.info("Loaded " + partitionsMap.size() + " partitions");