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:38:51 UTC
[29/32] 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/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-hbase1.x
Commit: 7d13664b205492ea1c0c7caa2269c11f0867290c
Parents: 4a689b2
Author: shaofengshi <sh...@apache.org>
Authored: Wed Nov 2 15:56:43 2016 +0800
Committer: shaofengshi <sh...@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 {