From 9c121a27315976fd16e1e919aa69592311e3e5de Mon Sep 17 00:00:00 2001
From: asdf2014 <1571805553@qq.com>
Date: Tue, 20 Jun 2017 14:14:37 +0800
Subject: [PATCH] PHOENIX-3961 Should delete `tableOutputPath` in
 `completebulkload`

---
 .../org/apache/phoenix/mapreduce/AbstractBulkLoadTool.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/AbstractBulkLoadTool.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/AbstractBulkLoadTool.java
index f7176475421..be2ac852e69 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/AbstractBulkLoadTool.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/AbstractBulkLoadTool.java
@@ -354,6 +354,10 @@ private void completebulkload(Configuration conf,Path outputPath , List<TargetTa
             LOG.info("Loading HFiles for {} from {}", tableName , tableOutputPath);
             loader.doBulkLoad(tableOutputPath, htable);
             LOG.info("Incremental load complete for table=" + tableName);
+
+            if (!tableOutputPath.getFileSystem(conf).delete(tableOutputPath, true)) {
+                LOG.error("Failed to delete the table output directory {}", tableOutputPath);
+            }
         }
     }