Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/19427#discussion_r148621269
--- Diff:
streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala ---
@@ -62,6 +63,7 @@ class Checkpoint(ssc: StreamingContext, val
checkpointTime: Time)
val newSparkConf = new SparkConf(loadDefaults =
false).setAll(sparkConfPairs)
.remove("spark.driver.host")
+ .remove("spark.driver.bindAddress")
--- End diff --
Do we have to remove this? It means we must drop `spark.driver.bindAddress`
if it's not set in the new run.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
