Enable

zsxwing · zsxwing · commit fa313e5fdd60 · 2016-11-29T00:08:56.000-08:00
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
@@ -844,7 +844,7 @@ class KafkaSourceStressForDontFailOnDataLossSuite extends StreamTest with Shared
     }
   }
 
-  ignore("stress test for failOnDataLoss=false") {
+  test("stress test for failOnDataLoss=false") {
     val reader = spark
       .readStream
       .format("kafka")

Original file line number	Diff line number	Diff line change
`@@ -844,7 +844,7 @@ class KafkaSourceStressForDontFailOnDataLossSuite extends StreamTest with Shared`
`844`	`844`	`}`
`845`	`845`	`}`
`846`	`846`
`847`		`- ignore("stress test for failOnDataLoss=false") {`
	`847`	`+ test("stress test for failOnDataLoss=false") {`
`848`	`848`	`val reader = spark`
`849`	`849`	`.readStream`
`850`	`850`	`.format("kafka")`