Skip to content

Commit d91977d

Browse files
committed
fix comments
1 parent 45330de commit d91977d

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ class KafkaContinuousSourceSuite extends KafkaSourceSuiteBase with KafkaContinuo
170170
}
171171
}
172172

173-
test(s"SPARK-27494: read kafka record containing null key/values in continuous mode") {
173+
test("SPARK-27494: read kafka record containing null key/values in continuous mode") {
174174
testNullableKeyValue(ContinuousTrigger(100))
175175
}
176176
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1041,7 +1041,7 @@ abstract class KafkaMicroBatchSourceSuiteBase extends KafkaSourceSuiteBase {
10411041
}
10421042
}
10431043

1044-
test(s"SPARK-27494: read kafka record containing null key/values in micro-batch mode") {
1044+
test("SPARK-27494: read kafka record containing null key/values in micro-batch mode") {
10451045
testNullableKeyValue(Trigger.ProcessingTime(100))
10461046
}
10471047
}

0 commit comments

Comments
 (0)