diff options
| author | jerryshao <saisai.shao@intel.com> | 2015-07-16 16:55:46 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-07-16 16:55:46 -0700 |
| commit | 031d7d41430ec1f3c3353e33eab4821a9bcd58a5 (patch) | |
| tree | 78c3abc0df6787b7910251f39f3123d2b8a35924 /streaming/src/main | |
| parent | fec10f0c63171bd5aff7a762a6c94df035f5fb52 (diff) | |
| download | spark-031d7d41430ec1f3c3353e33eab4821a9bcd58a5.tar.gz spark-031d7d41430ec1f3c3353e33eab4821a9bcd58a5.tar.bz2 spark-031d7d41430ec1f3c3353e33eab4821a9bcd58a5.zip | |
[SPARK-6304] [STREAMING] Fix checkpointing doesn't retain driver port issue.
Author: jerryshao <saisai.shao@intel.com>
Author: Saisai Shao <saisai.shao@intel.com>
Closes #5060 from jerryshao/SPARK-6304 and squashes the following commits:
89b01f5 [jerryshao] Update the unit test to add more cases
275d252 [jerryshao] Address the comments
7cc146d [jerryshao] Address the comments
2624723 [jerryshao] Fix rebase conflict
45befaa [Saisai Shao] Update the unit test
bbc1c9c [Saisai Shao] Fix checkpointing doesn't retain driver port issue
Diffstat (limited to 'streaming/src/main')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala b/streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala index 5279331c9e..65d4e933bf 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala @@ -48,6 +48,8 @@ class Checkpoint(@transient ssc: StreamingContext, val checkpointTime: Time) // Reload properties for the checkpoint application since user wants to set a reload property // or spark had changed its value and user wants to set it back. val propertiesToReload = List( + "spark.driver.host", + "spark.driver.port", "spark.master", "spark.yarn.keytab", "spark.yarn.principal") |