Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-12804 ImportTsv fails to delete partition files created by it (Ashish)

Browse Source
This commit is contained in:
tedyu 2015-01-05 09:29:36 -08:00
parent 173eba815b
commit a14723b435
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java
View File

@ -570,8 +570,8 @@ public class HFileOutputFormat2
FileSystem fs = FileSystem.get(job.getConfiguration()); FileSystem fs = FileSystem.get(job.getConfiguration());
Path partitionsPath = new Path("/tmp", "partitions_" + UUID.randomUUID()); Path partitionsPath = new Path("/tmp", "partitions_" + UUID.randomUUID());
fs.makeQualified(partitionsPath); fs.makeQualified(partitionsPath);
fs.deleteOnExit(partitionsPath);
writePartitions(job.getConfiguration(), partitionsPath, splitPoints); writePartitions(job.getConfiguration(), partitionsPath, splitPoints);
fs.deleteOnExit(partitionsPath);
// configure job to use it // configure job to use it
job.setPartitionerClass(TotalOrderPartitioner.class); job.setPartitionerClass(TotalOrderPartitioner.class);