Use 'stress' prefix instead

apache · Oct 6, 2016 · c7950f0 · c7950f0
1 parent 5158d5d
commit c7950f0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala b/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala
@@ -359,7 +359,8 @@ class KafkaSourceStressSuite extends KafkaSourceTest with BeforeAndAfter {
   }
 
   after {
-    for (topic <- testUtils.getAllTopicsAndPartitionSize().toMap.keys.filter(!_.startsWith("__"))) {
+    for (topic <-
+         testUtils.getAllTopicsAndPartitionSize().toMap.keys.filter(_.startsWith("stress"))) {
       testUtils.deleteTopic(topic)
     }
   }