Skip to content

Commit f79ba9f

Browse files
author
Anastasios Zouzias
committed
[SPARK-26121] minor fix
1 parent 39424dd commit f79ba9f

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceProvider.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -542,7 +542,8 @@ private[kafka010] object KafkaSourceProvider extends Logging {
542542
* Returns a unique consumer group (group.id), allowing the user to set the prefix of
543543
* the consumer group
544544
*/
545-
private def streamingUniqueGroupId(parameters: Map[String, String],
545+
private def streamingUniqueGroupId(
546+
parameters: Map[String, String],
546547
metadataPath: String): String = {
547548
val groupIdPrefix = parameters
548549
.getOrElse("groupIdPrefix", "spark-kafka-source")

0 commit comments

Comments
 (0)