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:43 UTC
[4/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/24168266
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/24168266
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/24168266
Branch: refs/heads/0.98
Commit: 24168266c82c681aaff6c25d32ab4be8f9c70458
Parents: 78380e1
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:37 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/24168266/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 b930f12..d1fe5e0 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
@@ -539,17 +539,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);
}
/**