Repository: kylin Updated Branches: refs/heads/v1.6.0-rc1 4a689b2db -> 7d13664b2
KYLIN-1726 drop kafka intermediate file on build complete Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/7d13664b Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/7d13664b Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/7d13664b Branch: refs/heads/v1.6.0-rc1 Commit: 7d13664b205492ea1c0c7caa2269c11f0867290c Parents: 4a689b2 Author: shaofengshi <shaofeng...@apache.org> Authored: Wed Nov 2 15:56:43 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Wed Nov 2 15:56:43 2016 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/7d13664b/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java ---------------------------------------------------------------------- diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java index 99ebb6a..8695276 100644 --- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java +++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/KafkaMRInput.java @@ -213,7 +213,6 @@ public class KafkaMRInput implements IMRInput { @Override protected ExecuteResult doWork(ExecutableContext context) throws ExecuteException { - StringBuffer output = new StringBuffer(); try { rmdirOnHDFS(getDataPath()); } catch (IOException e) { @@ -221,7 +220,7 @@ public class KafkaMRInput implements IMRInput { return new ExecuteResult(ExecuteResult.State.ERROR, e.getMessage()); } - return new ExecuteResult(ExecuteResult.State.SUCCEED, output.toString()); + return new ExecuteResult(ExecuteResult.State.SUCCEED, "HDFS path " + getDataPath() + " is dropped.\n"); } private void rmdirOnHDFS(String path) throws IOException {
