HeartSaVioR commented on a change in pull request #35238:
URL: https://github.com/apache/spark/pull/35238#discussion_r787301722
##########
File path:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchSourceSuite.scala
##########
@@ -199,9 +199,9 @@ abstract class KafkaMicroBatchSourceSuiteBase extends
KafkaSourceSuiteBase {
val topic = newTopic()
testUtils.createTopic(topic, partitions = 5)
- testUtils.sendMessages(topic, (0 until 15).map(x => {
- "foo-" + x
- }).toArray, Some(0))
+ testUtils.sendMessages(topic, (0 until 15).map{ case x =>
Review comment:
sorry for the nits: space between `p` and `{` / same happens in
foreachBatch
Not sure style checker will check this, but it is good practice to
run`dev/scalastyle` before pushing the change. Not all styles are checked with
style checker unfortunately.
Please go through https://github.com/databricks/scala-style-guide when you
have some time.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
