Skip to content

Commit 83a09cb

Browse files
committed
fix comments2
1 parent dbe6b3f commit 83a09cb

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -296,8 +296,9 @@ class KafkaTestUtils(withBrokerProps: Map[String, Object] = Map.empty) extends L
296296
props.put("replica.socket.timeout.ms", "1500")
297297
props.put("delete.topic.enable", "true")
298298
props.put("offsets.topic.num.partitions", "1")
299-
// props.putAll(withBrokerProps.asJava)
300-
withBrokerProps.foreach{ case (k, v) => props.put(k, v) }
299+
// Can not use properties.putAll(propsMap.asJava) in scala-2.12
300+
// See https://github.com/scala/bug/issues/10418
301+
withBrokerProps.foreach { case (k, v) => props.put(k, v) }
301302
props
302303
}
303304

0 commit comments

Comments
 (0)