Github user vanzin commented on the issue:
https://github.com/apache/spark/pull/21558
Actually I didn't mean speculation but something like this:
```
sc.parallelize(1 to 10).foreach { i => if
(TaskContext.get().attemptNumber() == 0) throw new Exception("Fail") else
println(i) }
```
Anyway I ran that and the behavior is the same (different attempt =
different task ID) so it's all good.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
