You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2015/02/14 04:19:42 UTC
[3/4] hbase git commit: HBASE-13010 HFileOutputFormat2 partitioner's
path is hard-coded as '/tmp'
HBASE-13010 HFileOutputFormat2 partitioner's path is hard-coded as '/tmp'
Signed-off-by: Andrew Purtell <ap...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/bd6fbea2
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/bd6fbea2
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/bd6fbea2
Branch: refs/heads/branch-1.0
Commit: bd6fbea2cec0ab6e052e2d1b64ea47f7716c5a77
Parents: 0280d71
Author: Aditya Kishore <ad...@mapr.com>
Authored: Fri Feb 13 18:35:33 2015 -0800
Committer: Andrew Purtell <ap...@apache.org>
Committed: Fri Feb 13 18:53:33 2015 -0800
----------------------------------------------------------------------
.../apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/bd6fbea2/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java
index 2b4e82d..fd160e4 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java
@@ -565,17 +565,17 @@ public class HFileOutputFormat2
*/
static void configurePartitioner(Job job, List<ImmutableBytesWritable> splitPoints)
throws IOException {
-
+ Configuration conf = job.getConfiguration();
// create the partitions file
- FileSystem fs = FileSystem.get(job.getConfiguration());
- Path partitionsPath = new Path("/tmp", "partitions_" + UUID.randomUUID());
+ FileSystem fs = FileSystem.get(conf);
+ Path partitionsPath = new Path(conf.get("hadoop.tmp.dir"), "partitions_" + UUID.randomUUID());
fs.makeQualified(partitionsPath);
- writePartitions(job.getConfiguration(), partitionsPath, splitPoints);
+ writePartitions(conf, partitionsPath, splitPoints);
fs.deleteOnExit(partitionsPath);
// configure job to use it
job.setPartitionerClass(TotalOrderPartitioner.class);
- TotalOrderPartitioner.setPartitionFile(job.getConfiguration(), partitionsPath);
+ TotalOrderPartitioner.setPartitionFile(conf, partitionsPath);
}
/**