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/56e600ff Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/56e600ff Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/56e600ff
Branch: refs/heads/KYLIN-1971 Commit: 56e600ffa984e89a78907a63708a3a7c0fa10fd7 Parents: cdd633c Author: shaofengshi <shaofeng...@apache.org> Authored: Wed Nov 2 15:56:43 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Wed Nov 2 16:05:11 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/56e600ff/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 {
