Skip to content

Commit 5713c20

Browse files
committed
Fix rebase conflict
1 parent d5098bf commit 5713c20

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ class Checkpoint(@transient ssc: StreamingContext, val checkpointTime: Time)
4343
val delaySeconds = MetadataCleaner.getDelaySeconds(ssc.conf)
4444
val sparkConfPairs = ssc.conf.getAll.filterNot { kv =>
4545
(!ssc.sc.isDriverHostSetByUser && kv._1 == "spark.driver.host") ||
46-
(!ssc.sc.isDriverPortSetByUser && kv._1 == "spark.driver.port")
46+
(!ssc.sc.isDriverPortSetByUser && kv._1 == "spark.driver.port") }
4747

4848
def createSparkConf(): SparkConf = {
4949
val newSparkConf = new SparkConf(loadDefaults = false).setAll(sparkConfPairs)

streaming/src/test/scala/org/apache/spark/streaming/CheckpointSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,7 @@ class CheckpointSuite extends TestSuiteBase {
209209
// Serialize/deserialize to simulate write to storage and reading it back
210210
val newCp = Utils.deserialize[Checkpoint](Utils.serialize(cp))
211211

212-
val newCpConf = newCp.sparkConf
212+
val newCpConf = newCp.createSparkConf()
213213
assert(newCpConf.contains("spark.driver.host"))
214214
assert(newCpConf.contains("spark.driver.port"))
215215
assert(newCpConf.get("spark.driver.host") === "localhost")

0 commit comments

Comments
 (0)