Author: eyang
Date: Fri Feb 27 18:10:10 2009
New Revision: 748623
URL: http://svn.apache.org/viewvc?rev=748623&view=rev
Log:
HADOOP-5309. Added --config to demux shell scripts. Log demux output to
chukwa log file.
Modified:
hadoop/core/trunk/src/contrib/chukwa/bin/dailyRolling.sh
hadoop/core/trunk/src/contrib/chukwa/bin/hourlyRolling.sh
hadoop/core/trunk/src/contrib/chukwa/bin/processSinkFiles.sh
Modified: hadoop/core/trunk/src/contrib/chukwa/bin/dailyRolling.sh
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/bin/dailyRolling.sh?rev=748623&r1=748622&r2=748623&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/chukwa/bin/dailyRolling.sh (original)
+++ hadoop/core/trunk/src/contrib/chukwa/bin/dailyRolling.sh Fri Feb 27
18:10:10 2009
@@ -20,7 +20,9 @@
bin=`cd "$bin"; pwd`
. "$bin"/chukwa-config.sh
-HADOOP_CONF_DIR="${HADOOP_HOME}/conf/"
+HADOOP_OPTS="$HADOOP_OPTS -DAPP=dailyRolling
-Dlog4j.configuration=chukwa-log4j.properties -DCHUKWA_HOME=${CHUKWA_HOME}
-DCHUKWA_CONF_DIR=${CHUKWA_CONF_DIR} -DCHUKWA_LOG_DIR=${CHUKWA_LOG_DIR} "
+export HADOOP_OPTS
+export HADOOP_CONF_DIR
HADOOP_CMDE="${HADOOP_HOME}/bin/hadoop "
$HADOOP_CMDE jar ${CHUKWA_CORE}
org.apache.hadoop.chukwa.extraction.demux.DailyChukwaRecordRolling
rollInSequence true deleteRawdata true
Modified: hadoop/core/trunk/src/contrib/chukwa/bin/hourlyRolling.sh
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/bin/hourlyRolling.sh?rev=748623&r1=748622&r2=748623&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/chukwa/bin/hourlyRolling.sh (original)
+++ hadoop/core/trunk/src/contrib/chukwa/bin/hourlyRolling.sh Fri Feb 27
18:10:10 2009
@@ -20,7 +20,9 @@
bin=`cd "$bin"; pwd`
. "$bin"/chukwa-config.sh
-HADOOP_CONF_DIR="${HADOOP_HOME}/conf/"
+HADOOP_OPTS="$HADOOP_OPTS -DAPP=hourlyRolling
-Dlog4j.configuration=chukwa-log4j.properties -DCHUKWA_HOME=${CHUKWA_HOME}
-DCHUKWA_CONF_DIR=${CHUKWA_CONF_DIR} -DCHUKWA_LOG_DIR=${CHUKWA_LOG_DIR} "
+export HADOOP_OPTS
+export HADOOP_CONF_DIR
HADOOP_CMDE="${HADOOP_HOME}/bin/hadoop "
$HADOOP_CMDE jar ${CHUKWA_CORE}
org.apache.hadoop.chukwa.extraction.demux.HourlyChukwaRecordRolling
rollInSequence true deleteRawdata true
Modified: hadoop/core/trunk/src/contrib/chukwa/bin/processSinkFiles.sh
URL:
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/bin/processSinkFiles.sh?rev=748623&r1=748622&r2=748623&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/chukwa/bin/processSinkFiles.sh (original)
+++ hadoop/core/trunk/src/contrib/chukwa/bin/processSinkFiles.sh Fri Feb 27
18:10:10 2009
@@ -27,7 +27,6 @@
trap 'remove_cron;rm -f
$CHUKWA_HOME/var/run/chukwa-$CHUKWA_IDENT_STRING-processSinkFiles.sh.pid
${CHUKWA_HOME}/var/run/ProcessSinkFiles.pid; exit 0' 1 2 15
echo "${pid}" > "$CHUKWA_HOME/var/run/ProcessSinkFiles.pid"
-HADOOP_CMDE="${HADOOP_HOME}/bin/hadoop "
function remove_cron {
mkdir -p ${CHUKWA_HOME}/var/tmp >&/dev/null
@@ -45,15 +44,15 @@
if [ "X${crontest}" != "X0" ]; then
cat > ${CHUKWA_HOME}/var/tmp/cron.${CURRENT_DATE} << CRON
-16 * * * * ${CHUKWA_HOME}/bin/hourlyRolling.sh >&
${CHUKWA_HOME}/logs/hourly.log
-30 1 * * * ${CHUKWA_HOME}/bin/dailyRolling.sh >&
${CHUKWA_HOME}/logs/dailyRolling.log
+16 * * * * ${CHUKWA_HOME}/bin/hourlyRolling.sh --config ${CHUKWA_CONF_DIR} >&
${CHUKWA_LOG_DIR}/hourly.log
+30 1 * * * ${CHUKWA_HOME}/bin/dailyRolling.sh --config ${CHUKWA_CONF_DIR} >&
${CHUKWA_LOG_DIR}/dailyRolling.log
CRON
else
grep -v "${CHUKWA_HOME}/bin/hourlyRolling.sh"
${CHUKWA_HOME}/var/tmp/cron.${CURRENT_DATE} | grep -v
"${CHUKWA_HOME}/bin/dailyRolling.sh" >
${CHUKWA_HOME}/var/tmp/cron.${CURRENT_DATE}.2
mv ${CHUKWA_HOME}/var/tmp/cron.${CURRENT_DATE}.2
${CHUKWA_HOME}/var/tmp/cron.${CURRENT_DATE}
cat >> ${CHUKWA_HOME}/var/tmp/cron.${CURRENT_DATE} << CRON
-16 * * * * ${CHUKWA_HOME}/bin/hourlyRolling.sh >&
${CHUKWA_HOME}/logs/hourly.log
-30 1 * * * ${CHUKWA_HOME}/bin/dailyRolling.sh >&
${CHUKWA_HOME}/logs/dailyRolling.log
+16 * * * * ${CHUKWA_HOME}/bin/hourlyRolling.sh --config ${CHUKWA_CONF_DIR} >&
${CHUKWA_LOG_DIR}/hourly.log
+30 1 * * * ${CHUKWA_HOME}/bin/dailyRolling.sh --config ${CHUKWA_CONF_DIR} >&
${CHUKWA_LOG_DIR}/dailyRolling.log
CRON
fi
@@ -75,6 +74,12 @@
add_cron
fi
+
+HADOOP_OPTS="$HADOOP_OPTS -DAPP=demux
-Dlog4j.configuration=chukwa-log4j.properties -DCHUKWA_HOME=${CHUKWA_HOME}
-DCHUKWA_CONF_DIR=${CHUKWA_CONF_DIR} -DCHUKWA_LOG_DIR=${CHUKWA_LOG_DIR} "
+export HADOOP_OPTS
+export HADOOP_CONF_DIR
+HADOOP_CMDE="${HADOOP_HOME}/bin/hadoop "
+
while [ 1 ]
do
debugDate=`date `