aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/rdd.py
diff options
context:
space:
mode:
authorAaron Davidson <aaron@databricks.com>2014-03-07 10:22:27 -0800
committerAaron Davidson <aaron@databricks.com>2014-03-07 10:22:27 -0800
commitdabeb6f160f7ad7df1c54b1b8b069700dd4b74dd (patch)
tree1abbe46bae3890ec2924e87366d36d3e8d7e22cb /python/pyspark/rdd.py
parent33baf14b04bcb5cb8dc39ae0773b9e0ef79ef9cf (diff)
downloadspark-dabeb6f160f7ad7df1c54b1b8b069700dd4b74dd.tar.gz
spark-dabeb6f160f7ad7df1c54b1b8b069700dd4b74dd.tar.bz2
spark-dabeb6f160f7ad7df1c54b1b8b069700dd4b74dd.zip
SPARK-1136: Fix FaultToleranceTest for Docker 0.8.1
This patch allows the FaultToleranceTest to work in newer versions of Docker. See https://spark-project.atlassian.net/browse/SPARK-1136 for more details. Besides changing the Docker and FaultToleranceTest internals, this patch also changes the behavior of Master to accept new Workers which share an address with a Worker that we are currently trying to recover. This can only happen when the Worker itself was restarted and got the same IP address/port at the same time as a Master recovery occurs. Finally, this adds a good bit of ASCII art to the test to make failures, successes, and actions more apparent. This is very much needed. Author: Aaron Davidson <aaron@databricks.com> Closes #5 from aarondav/zookeeper and squashes the following commits: 5d7a72a [Aaron Davidson] SPARK-1136: Fix FaultToleranceTest for Docker 0.8.1
Diffstat (limited to 'python/pyspark/rdd.py')
0 files changed, 0 insertions, 0 deletions