Hi, I am writing a streaming job that reads a Kafka topic. As far as I understand, Spark does a 1:1 mapping between its executors and Kafka partitions.
In order to correctly implement my checkpoint logic, I'd like to know what exactly happens when an executors crashes. Also, is it possible to kill an executor manually for testing purposes? Thank you. Samy --------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org
