You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2016/11/02 08:05:22 UTC
[3/3] kylin git commit: KYLIN-1726 drop kafka intermediate file on
build complete
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/master
Commit: 56e600ffa984e89a78907a63708a3a7c0fa10fd7
Parents: cdd633c
Author: shaofengshi <sh...@apache.org>
Authored: Wed Nov 2 15:56:43 2016 +0800
Committer: shaofengshi <sh...@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 {