diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-25 14:01:16 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-25 14:01:16 -0800 |
| commit | 6b87ef7c8625260e6b99cd6c6ebd16761efd5cda (patch) | |
| tree | f3bf44d044d96789456e29e3627a97d0b6bf870e /examples/src | |
| parent | 01bd136ba5c5f47a82b67b8d34df5a6aeaf79080 (diff) | |
| download | spark-6b87ef7c8625260e6b99cd6c6ebd16761efd5cda.tar.gz spark-6b87ef7c8625260e6b99cd6c6ebd16761efd5cda.tar.bz2 spark-6b87ef7c8625260e6b99cd6c6ebd16761efd5cda.zip | |
Fix compile error
Diffstat (limited to 'examples/src')
| -rw-r--r-- | examples/src/main/scala/spark/streaming/examples/QueueStream.scala | 2 | ||||
| -rw-r--r-- | examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/examples/src/main/scala/spark/streaming/examples/QueueStream.scala b/examples/src/main/scala/spark/streaming/examples/QueueStream.scala index d83db7784d..e9cb7b55ea 100644 --- a/examples/src/main/scala/spark/streaming/examples/QueueStream.scala +++ b/examples/src/main/scala/spark/streaming/examples/QueueStream.scala @@ -30,7 +30,7 @@ object QueueStream { // Create and push some RDDs into for (i <- 1 to 30) { - rddQueue += sc.sparkContext.makeRDD(1 to 1000, 10) + rddQueue += ssc.sparkContext.makeRDD(1 to 1000, 10) Thread.sleep(1000) } ssc.stop() diff --git a/examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala b/examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala index cce0001426..49b3223eec 100644 --- a/examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala +++ b/examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala @@ -34,7 +34,7 @@ object RawNetworkGrep { val ssc = new StreamingContext(master, "RawNetworkGrep", Milliseconds(batchMillis)) // Warm up the JVMs on master and slave for JIT compilation to kick in - RawTextHelper.warmUp(sc.sparkContext) + RawTextHelper.warmUp(ssc.sparkContext) val rawStreams = (1 to numStreams).map(_ => ssc.rawSocketStream[String](host, port, StorageLevel.MEMORY_ONLY_SER_2)).toArray |