I understand that duplicate results due to speculation for handled at driver side. But what if one of my spark task ( in a streaming scenario ) involves sending a message to ActiveMQ. Here driver has no control over it and once message is sent it's done. How is this handled?
-- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/How-to-handle-ActiveMQ-message-produce-in-case-of-spark-speculation-tp26795.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
