From 49885436305c99dcb3d28bc6645ad3491113eaf3 Mon Sep 17 00:00:00 2001 From: Kshitij Gautam Date: Wed, 19 Sep 2018 15:09:31 -0700 Subject: [PATCH] do not delete the partitions file if the session is closed --- .../main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java | 1 - 1 file changed, 1 deletion(-) diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java index 0063c56a99..7650e8f965 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java @@ -824,7 +824,6 @@ public class HFileOutputFormat2 Path partitionsPath = new Path(hbaseTmpFsDir, "partitions_" + UUID.randomUUID()); fs.makeQualified(partitionsPath); writePartitions(conf, partitionsPath, splitPoints, writeMultipleTables); - fs.deleteOnExit(partitionsPath); // configure job to use it job.setPartitionerClass(TotalOrderPartitioner.class); -- 2.12.2