.setMaster("local") set it to local[2] or local[*]
Thanks
Best Regards
On Thu, Jun 18, 2015 at 5:59 PM, Bartek Radziszewski
wrote:
> hi,
> I'm trying to run simple kafka spark streaming example over spark-shell:
>
> sc.stop
> import org.apache.spark.SparkConf
> import org.apache.spark.SparkCont
hi,
I'm trying to run simple kafka spark streaming example over spark-shell:
sc.stop
import org.apache.spark.SparkConf
import org.apache.spark.SparkContext._
import kafka.serializer.DefaultDecoder
import org.apache.spark.streaming._
import org.apache.spark.streaming.kafka._
import org.apache.spar
