I am using spark streaming for a basic streaming movie count program. So I first I have mapped the year and movie name to a JavaPairRDD and I am using the reduceByKey cor counting the movie year wise.
I am using cassandra for output, the spark streaming application is not stopping and the cassandra is also not showing any output. I think the data should be staging, If so how do I stop my spark streaming application regards, Sathya
