You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/03/14 01:02:49 UTC
[37/47] incubator-kylin git commit: Add more logs in hadoop job
Add more logs in hadoop job
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/93f1f26e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/93f1f26e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/93f1f26e
Branch: refs/heads/master
Commit: 93f1f26e3e1f07ecd3919517a82c0bb9faadc4a3
Parents: 6074fb4
Author: Shao Feng, Shi <sh...@ebay.com>
Authored: Tue Mar 10 15:21:12 2015 +0800
Committer: Shao Feng, Shi <sh...@ebay.com>
Committed: Tue Mar 10 15:21:12 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/job/execution/AbstractExecutable.java | 1 +
.../main/java/org/apache/kylin/job/hadoop/AbstractHadoopJob.java | 1 +
2 files changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/93f1f26e/job/src/main/java/org/apache/kylin/job/execution/AbstractExecutable.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/execution/AbstractExecutable.java b/job/src/main/java/org/apache/kylin/job/execution/AbstractExecutable.java
index c0c6160..4e15709 100644
--- a/job/src/main/java/org/apache/kylin/job/execution/AbstractExecutable.java
+++ b/job/src/main/java/org/apache/kylin/job/execution/AbstractExecutable.java
@@ -98,6 +98,7 @@ public abstract class AbstractExecutable implements Executable, Idempotent {
onExecuteStart(executableContext);
result = doWork(executableContext);
} catch (Throwable e) {
+ logger.error("error running Executable", e);
onExecuteError(e, executableContext);
throw new ExecuteException(e);
}
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/93f1f26e/job/src/main/java/org/apache/kylin/job/hadoop/AbstractHadoopJob.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/AbstractHadoopJob.java b/job/src/main/java/org/apache/kylin/job/hadoop/AbstractHadoopJob.java
index a8dc687..ff19357 100644
--- a/job/src/main/java/org/apache/kylin/job/hadoop/AbstractHadoopJob.java
+++ b/job/src/main/java/org/apache/kylin/job/hadoop/AbstractHadoopJob.java
@@ -161,6 +161,7 @@ public abstract class AbstractHadoopJob extends Configured implements Tool {
jobConf.set(MAP_REDUCE_CLASSPATH, classpath + "," + kylinHiveDependency);
}
}
+ logger.info("Hadoop job classpath is: " + job.getConfiguration().get(MAP_REDUCE_CLASSPATH));
}
public void addInputDirs(String input, Job job) throws IOException {