Hi
I ve written a spark streaming code which streams data from flume to kafka
which is received by spark.
I ve used update state by key and then for each rdd im saving them into
cassandra and elsatic search(by calling 2 different methods).
The above parts are working fine when streaming job is
Yes the data is getting processed. I printed the data and the rdd count. The
point where data is getting saved is not invoked. I am using the same class
and jar for submitting by both methods. Only difference is I am launching by
tomcat and there directly by putty.
--
View this message in
