Skip to content

Commit 275d252

Browse files
committed
Address the comments
1 parent 7cc146d commit 275d252

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,11 +48,11 @@ class Checkpoint(@transient ssc: StreamingContext, val checkpointTime: Time)
4848
// Reload properties for the checkpoint application since user wants to set a reload property
4949
// or spark had changed its value and user wants to set it back.
5050
val propertiesToReload = List(
51+
"spark.driver.host",
52+
"spark.driver.port",
5153
"spark.master",
5254
"spark.yarn.keytab",
53-
"spark.yarn.principal",
54-
"spark.driver.host",
55-
"spark.driver.port")
55+
"spark.yarn.principal")
5656

5757
val newSparkConf = new SparkConf(loadDefaults = false).setAll(sparkConfPairs)
5858
.remove("spark.driver.host")

0 commit comments

Comments
 (0)