diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2012-11-12 21:45:16 +0000 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2012-11-12 21:45:16 +0000 |
| commit | ae61ebaee64fad117155d65bcdfc8520bda0e6b4 (patch) | |
| tree | 12e0c6f0ddc70cfce11961f0ecd263c147eb10f0 /run | |
| parent | 052d0b800ffe1bcfddc33a6fb3ad71e169b219bb (diff) | |
| download | spark-ae61ebaee64fad117155d65bcdfc8520bda0e6b4.tar.gz spark-ae61ebaee64fad117155d65bcdfc8520bda0e6b4.tar.bz2 spark-ae61ebaee64fad117155d65bcdfc8520bda0e6b4.zip | |
Fixed bugs in RawNetworkInputDStream and in its examples. Made the ReducedWindowedDStream persist RDDs to MEMOERY_SER_ONLY by default. Removed unncessary examples. Added streaming-env.sh.template to add recommended setting for streaming.
Diffstat (limited to 'run')
| -rwxr-xr-x | run | 4 |
1 files changed, 4 insertions, 0 deletions
@@ -13,6 +13,10 @@ if [ -e $FWDIR/conf/spark-env.sh ] ; then . $FWDIR/conf/spark-env.sh fi +if [ -e $FWDIR/conf/streaming-env.sh ] ; then + . $FWDIR/conf/streaming-env.sh +fi + if [ "$SPARK_LAUNCH_WITH_SCALA" == "1" ]; then if [ `command -v scala` ]; then RUNNER="scala" |