subtract is not the issue. Spark is lazy so a lot of times you'd have many,
many lines of code which does not in fact run until you do some action (in
your case, subtract). As you can see from the stacktrace, the NPE is from
joda which is used in the partitioner (Im suspecting in Cassandra).But the
Hi All,
I am seeing exception when trying to substract 2 rdds.
Lets say rdd1 has messages like -
* pnr, bookingId, BookingObject*
101, 1, BookingObject1 // - event number is 0
102, 1, BookingObject2// - event number is 0
103, 2, Bo
