hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject [2/4] hbase git commit: HBASE-13010 HFileOutputFormat2 partitioner's path is hard-coded as '/tmp'
Date Sat, 14 Feb 2015 03:19:41 GMT
HBASE-13010 HFileOutputFormat2 partitioner's path is hard-coded as '/tmp'

Signed-off-by: Andrew Purtell <apurtell@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/432b2197
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/432b2197
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/432b2197

Branch: refs/heads/branch-1
Commit: 432b2197fdee4f1615d6ef651b1102faf16a48a5
Parents: 9114ede
Author: Aditya Kishore <aditya@mapr.com>
Authored: Fri Feb 13 18:35:33 2015 -0800
Committer: Andrew Purtell <apurtell@apache.org>
Committed: Fri Feb 13 18:53:26 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/432b2197/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 6572684..465be56 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
@@ -585,17 +585,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);
   }
 
   /**


Mime
View raw message