HBASE-12804 ImportTsv fails to delete partition files created by it (Ashish)
This commit is contained in:
parent
ac95cc1fbb
commit
2ba6053163
|
@ -590,8 +590,8 @@ public class HFileOutputFormat2
|
|||
FileSystem fs = FileSystem.get(job.getConfiguration());
|
||||
Path partitionsPath = new Path("/tmp", "partitions_" + UUID.randomUUID());
|
||||
fs.makeQualified(partitionsPath);
|
||||
fs.deleteOnExit(partitionsPath);
|
||||
writePartitions(job.getConfiguration(), partitionsPath, splitPoints);
|
||||
fs.deleteOnExit(partitionsPath);
|
||||
|
||||
// configure job to use it
|
||||
job.setPartitionerClass(TotalOrderPartitioner.class);
|
||||
|
|
Loading…
Reference in New Issue