diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java index 51b5941..dfd6e02 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java @@ -538,7 +538,7 @@ private void handleSampling(DriverContext context, MapWork mWork, JobConf job, H fetchWork.setSource(ts); // random sampling - FetchOperator fetcher = PartitionKeySampler.createSampler(fetchWork, conf, job, ts); + FetchOperator fetcher = PartitionKeySampler.createSampler(fetchWork, conf, new JobConf(job), ts); try { ts.initialize(conf, new ObjectInspector[]{fetcher.getOutputObjectInspector()}); OperatorUtils.setChildrenCollector(ts.getChildOperators(), sampler); diff --git ql/src/java/org/apache/hadoop/hive/ql/plan/MapWork.java ql/src/java/org/apache/hadoop/hive/ql/plan/MapWork.java index 3217df2..84bdb78 100644 --- ql/src/java/org/apache/hadoop/hive/ql/plan/MapWork.java +++ ql/src/java/org/apache/hadoop/hive/ql/plan/MapWork.java @@ -444,7 +444,7 @@ public String getIndexIntermediateFile() { } public ArrayList getPartitionDescs() { - return new ArrayList(aliasToPartnInfo.values()); + return new ArrayList(pathToPartitionInfo.values()); } public Path getTmpHDFSPath() {