, Bartek Radziszewski bar...@scalaric.com
wrote:
Hey,
I’m trying to run kafka spark streaming using mesos with following example:
*sc.stop*
*import org.apache.spark.SparkConf*
*import org.apache.spark.SparkContext._*
*import kafka.serializer.StringDecoder*
*import org.apache.spark.streaming
Hey,
I’m trying to run kafka spark streaming using mesos with following example:
sc.stop
import org.apache.spark.SparkConf
import org.apache.spark.SparkContext._
import kafka.serializer.StringDecoder
import org.apache.spark.streaming._
import org.apache.spark.streaming.kafka._
import