File tree Expand file tree Collapse file tree 2 files changed +2
-5
lines changed
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010 Expand file tree Collapse file tree 2 files changed +2
-5
lines changed Original file line number Diff line number Diff line change 2020FWDIR=" $( cd " ` dirname $0 ` " /..; pwd) "
2121cd " $FWDIR "
2222
23- build/sbt -Pyarn -Phadoop-2.6 -Dhadoop.version=2.6.0 " project sql-kafka-0-10" " test-only *KafkaSourceSuite*"
24-
25- # exec python -u ./dev/run-tests.py "$@"
23+ exec python -u ./dev/run-tests.py " $@ "
Original file line number Diff line number Diff line change @@ -311,8 +311,7 @@ class KafkaSourceSuite extends KafkaSourceTest {
311311 }
312312 }
313313
314- for (idx <- 1 to 100 )
315- test(s " subscribing topic by pattern with topic deletions $idx" ) {
314+ test(" subscribing topic by pattern with topic deletions" ) {
316315 val topicPrefix = newTopic()
317316 val topic = topicPrefix + " -seems"
318317 val topic2 = topicPrefix + " -bad"
You can’t perform that action at this time.
0 commit comments