Fix compile error
This commit is contained in:
parent
01bd136ba5
commit
6b87ef7c86
|
@ -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()
|
||||
|
|
|
@ -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
|
||||
|
|
Loading…
Reference in a new issue