Top "Spark-streaming" questions

com.fasterxml.jackson.databind.JsonMappingException: Jackson version is too old 2.5.3

My OS is OS X 10.11.6. I'm running Spark 2.0, Zeppelin 0.6, Scala 2.11 When I run this code in Zeppelin I get an …

apache-spark maven-2 spark-streaming apache-zeppelin fasterxml

Getting java.lang.IllegalArgumentException: requirement failed while calling Sparks MLLIB StreamingKMeans from java application

I am new to Spark and MLlib and I'm trying to call StreamingKMeans from my java application and I get …

java apache-spark bigdata hadoop2 spark-streaming

Stop streaming context in Spark Streaming after a period of time

I building an application which receives DStreams from Twitter, the only way to stop the Streaming context is by stoping …

stream apache-spark twitter4j spark-streaming

How to add the "--deploy-mode cluster" option to my scala code

209/5000 Hello I want to add the option "--deploy-mode cluster" to my code scala: val sparkConf = new SparkConfig ().setMaster ("spark: //192.168.60.80:7077") Without …

scala apache-spark spark-streaming apache-spark-standalone

Spark Streaming Kafka stream

I'm having some issues while trying to read from kafka with spark streaming. My code is: val sparkConf = new SparkConf().…

apache-spark apache-kafka spark-streaming spark-streaming-kafka