Add missing leading 's'

tedyu · tedyu · commit 758378e72ed9 · 2018-06-05T06:48:31.000-07:00
diff --git a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala b/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala
@@ -128,7 +128,7 @@ class KafkaTestUtils(withBrokerProps: Map[String, Object] = Map.empty) extends L
 
     brokerReady = true
     val props = new Properties()
-    props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, "$brokerHost:$brokerPort")
+    props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, s"$brokerHost:$brokerPort")
     adminClient = AdminClient.create(props)
   }
 

Original file line number	Diff line number	Diff line change
`@@ -128,7 +128,7 @@ class KafkaTestUtils(withBrokerProps: Map[String, Object] = Map.empty) extends L`
`128`	`128`
`129`	`129`	`brokerReady = true`
`130`	`130`	`val props = new Properties()`
`131`		`- props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, "$brokerHost:$brokerPort")`
	`131`	`+ props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, s"$brokerHost:$brokerPort")`
`132`	`132`	`adminClient = AdminClient.create(props)`
`133`	`133`	`}`
`134`	`134`