[SPARK-18671][SS][TEST-MAVEN] Follow up PR to fix test for Maven

## What changes were proposed in this pull request? Maven compilation seem to not allow resource is sql/test to be easily referred to in kafka-0-10-sql tests. So moved the kafka-source-offset-version-2.1.0 from sql test resources to kafka-0-10-sql test resources. ## How was this patch tested? Manually ran maven test Author: Tathagata Das <[email protected]> Closes #16183 from tdas/SPARK-18671-1.
apache · Dec 7, 2016 · 5c6bcdb · 5c6bcdb
1 parent 08d6441
commit 5c6bcdb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...ing/kafka-source-offset-version-2.1.0.txt → ...ces/kafka-source-offset-version-2.1.0.txt b/...ing/kafka-source-offset-version-2.1.0.txt → ...ces/kafka-source-offset-version-2.1.0.txt
diff --git a/.../kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceOffsetSuite.scala b/.../kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceOffsetSuite.scala
@@ -98,7 +98,8 @@ class KafkaSourceOffsetSuite extends OffsetSuite with SharedSQLContext {
 
   private def readFromResource(file: String): SerializedOffset = {
     import scala.io.Source
-    val str = Source.fromFile(getClass.getResource(s"/structured-streaming/$file").toURI).mkString
+    val input = getClass.getResource(s"/$file").toURI
+    val str = Source.fromFile(input).mkString
     SerializedOffset(str)
   }
 }