You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/11/08 09:27:27 UTC
[3/3] incubator-kylin git commit: force streaming proecess to use
correct log4j properties
force streaming proecess to use correct log4j properties
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/bdada03f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/bdada03f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/bdada03f
Branch: refs/heads/devstreaming
Commit: bdada03f70a103dcd273356c3eb1cebefc43f4c9
Parents: b66c258
Author: honma <ho...@ebay.com>
Authored: Thu Oct 15 16:59:31 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Thu Oct 15 16:59:31 2015 +0800
----------------------------------------------------------------------
bin/kylin.sh | 9 +--------
.../java/org/apache/kylin/job/streaming/StreamingCLI.java | 7 +++++++
2 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/bdada03f/bin/kylin.sh
----------------------------------------------------------------------
diff --git a/bin/kylin.sh b/bin/kylin.sh
index 2e9cf24..cecee27 100644
--- a/bin/kylin.sh
+++ b/bin/kylin.sh
@@ -91,11 +91,6 @@ then
fi
if [ $2 == "start" ]
then
- useSandbox=`sh ${dir}/get-properties.sh kylin.sandbox`
- spring_profile="default"
- if [ "$useSandbox" = "true" ]
- then spring_profile="sandbox"
- fi
#retrive $hive_dependency and $hbase_dependency
source ${dir}/find-hive-dependency.sh
@@ -110,11 +105,9 @@ then
# KYLIN_EXTRA_START_OPTS is for customized settings, checkout bin/setenv.sh
hbase ${KYLIN_EXTRA_START_OPTS} \
- -Djava.util.logging.manager=org.apache.juli.ClassLoaderLogManager \
- -Dorg.apache.catalina.connector.CoyoteAdapter.ALLOW_BACKSLASH=true \
-Dkylin.hive.dependency=${hive_dependency} \
-Dkylin.hbase.dependency=${hbase_dependency} \
- -Dspring.profiles.active=${spring_profile} \
+ -Dlog4j.configuration=kylinlog4j.properties \
org.apache.kylin.job.streaming.StreamingCLI $@ > ${KYLIN_HOME}/logs/streaming_$3_$4.log 2>&1 & echo $! > ${KYLIN_HOME}/logs/$3_$4 &
echo "streaming started name: $3 id: $4"
exit 0
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/bdada03f/job/src/main/java/org/apache/kylin/job/streaming/StreamingCLI.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/streaming/StreamingCLI.java b/job/src/main/java/org/apache/kylin/job/streaming/StreamingCLI.java
index 8346ec0..a8bbb8a 100644
--- a/job/src/main/java/org/apache/kylin/job/streaming/StreamingCLI.java
+++ b/job/src/main/java/org/apache/kylin/job/streaming/StreamingCLI.java
@@ -51,6 +51,12 @@ public class StreamingCLI {
public static void main(String[] args) {
try {
+ System.out.println("hi");
+ logger.info("In StreamingCLI");
+ for (String arg : args) {
+ logger.info(arg);
+ }
+
AbstractRestCache.setCacheUpdater(new RemoteCacheUpdater());
Preconditions.checkArgument(args[0].equals("streaming"));
@@ -91,6 +97,7 @@ public class StreamingCLI {
logger.info("streaming process stop, exit with 0");
System.exit(0);
} catch (Exception e) {
+ e.printStackTrace();
printArgsError(args);
logger.error("error start streaming", e);
System.exit(-1);