fix import

xuanyuanking · xuanyuanking · commit fa641878f3aa · 2018-01-04T21:19:32.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
@@ -319,7 +319,7 @@ class KafkaSourceSuite extends KafkaSourceTest {
   }
 
   test("union bug in failover") {
-    def getSpecificDF(range: Range.Inclusive): Dataset[Int] = {
+    def getSpecificDF(range: Range.Inclusive): org.apache.spark.sql.Dataset[Int] = {
       val topic = newTopic()
       testUtils.createTopic(topic, partitions = 1)
       testUtils.sendMessages(topic, range.map(_.toString).toArray, Some(0))

Original file line number	Diff line number	Diff line change
`@@ -319,7 +319,7 @@ class KafkaSourceSuite extends KafkaSourceTest {`
`319`	`319`	`}`
`320`	`320`
`321`	`321`	`test("union bug in failover") {`
`322`		`- def getSpecificDF(range: Range.Inclusive): Dataset[Int] = {`
	`322`	`+ def getSpecificDF(range: Range.Inclusive): org.apache.spark.sql.Dataset[Int] = {`
`323`	`323`	`val topic = newTopic()`
`324`	`324`	`testUtils.createTopic(topic, partitions = 1)`
`325`	`325`	`testUtils.sendMessages(topic, range.map(_.toString).toArray, Some(0))`