Fix

zsxwing · zsxwing · commit c70ff19fb404 · 2016-12-07T00:11:12.000-08:00
diff --git a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala b/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala
@@ -184,7 +184,7 @@ class KafkaTestUtils extends Logging {
   def deleteTopic(topic: String): Unit = {
     val partitions = zkUtils.getPartitionsForTopics(Seq(topic))(topic).size
     AdminUtils.deleteTopic(zkUtils, topic)
-    verifyTopicDeletion(zkUtils, topic, partitions, List(this.server))
+    verifyTopicDeletionWithRetries(zkUtils, topic, partitions, List(this.server))
   }
 
   /** Add new paritions to a Kafka topic */

Original file line number	Diff line number	Diff line change
`@@ -184,7 +184,7 @@ class KafkaTestUtils extends Logging {`
`184`	`184`	`def deleteTopic(topic: String): Unit = {`
`185`	`185`	`val partitions = zkUtils.getPartitionsForTopics(Seq(topic))(topic).size`
`186`	`186`	`AdminUtils.deleteTopic(zkUtils, topic)`
`187`		`- verifyTopicDeletion(zkUtils, topic, partitions, List(this.server))`
	`187`	`+ verifyTopicDeletionWithRetries(zkUtils, topic, partitions, List(this.server))`
`188`	`188`	`}`
`189`	`189`
`190`	`190`	`/** Add new paritions to a Kafka topic */`