Skip to content

Commit

Permalink
modify start-local script
Browse files Browse the repository at this point in the history
  • Loading branch information
allwefantasy committed Nov 15, 2018
1 parent e64f470 commit 29f82d4
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions dev/start-local.sh
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@ if [ -z "${MLSQL_HOME}" ]; then
fi

JARS=$(echo ${MLSQL_HOME}/libs/*.jar | tr ' ' ',')
MAIN_AJR=$(ls libs|grep 'streamingpro-mlsql')
$SPARK_HOME/bin/spark-submit --class streaming.core.StreamingApp \
--jars ${JARS} \
--master local[*] \
Expand All @@ -21,9 +22,8 @@ $SPARK_HOME/bin/spark-submit --class streaming.core.StreamingApp \
--conf "spark.kryoserializer.buffer.max=1024m" \
--conf "spark.serializer=org.apache.spark.serializer.KryoSerializer" \
--conf "spark.scheduler.mode=FAIR" \
${MLSQL_HOME}/libs/streamingpro-mlsql-1.1.3.jar \
${MLSQL_HOME}/libs/${MAIN_AJR} \
-streaming.name mlsql \
-streaming.job.file.path ${MLSQL_HOME}/empty.json \
-streaming.platform spark \
-streaming.rest true \
-streaming.driver.port 9003 \
Expand Down

0 comments on commit 29f82d4

Please sign in to comment.