apache-spark-on-k8s / spark

Apache Spark enhanced with native Kubernetes scheduler back-end: NOTE this repository is being ARCHIVED as all new development for the kubernetes scheduler back-end is now on https://github.com/apache/spark/
https://spark.apache.org/
Apache License 2.0
612 stars 118 forks source link

emit shuffle pod watch exception #601

Open ChenLingPeng opened 6 years ago

ChenLingPeng commented 6 years ago

Signed-off-by: forrestchen forrestchen@tencent.com

What changes were proposed in this pull request?

(Please fill in changes proposed in this fix)

How was this patch tested?

manual test.

Run the PageRank example and below error occur image

the reason is when after fire a watch on shuffle pods, watcher will receive an ADDED event and raise an exception because it exist in shuffle pod cache. check if the pod ip is the same to avoid this issue