hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject [1/4] hbase git commit: HBASE-13010 HFileOutputFormat2 partitioner's path is hard-coded as '/tmp'
Date Sat, 14 Feb 2015 03:19:40 GMT
Repository: hbase
Updated Branches:
  refs/heads/0.98 78380e166 -> 24168266c
  refs/heads/branch-1 9114edece -> 432b2197f
  refs/heads/branch-1.0 0280d7193 -> bd6fbea2c
  refs/heads/master c96df5e24 -> f286797fb


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/f286797f
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/f286797f
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/f286797f

Branch: refs/heads/master
Commit: f286797fbf063a929b0dc841c6071edb8eae2dd6
Parents: c96df5e
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:35: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/f286797f/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 f69f21f..f2d5c6f 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
@@ -584,17 +584,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