From a96c06483331518d2ff6a857315e6c82a29e3366 Mon Sep 17 00:00:00 2001 From: Tathagata Das Date: Tue, 6 Dec 2016 17:38:41 -0800 Subject: [PATCH] Fix test --- .../src/test/resources}/kafka-source-offset-version-2.1.0.txt | 0 .../org/apache/spark/sql/kafka010/KafkaSourceOffsetSuite.scala | 3 ++- 2 files changed, 2 insertions(+), 1 deletion(-) rename {sql/core/src/test/resources/structured-streaming => external/kafka-0-10-sql/src/test/resources}/kafka-source-offset-version-2.1.0.txt (100%) diff --git a/sql/core/src/test/resources/structured-streaming/kafka-source-offset-version-2.1.0.txt b/external/kafka-0-10-sql/src/test/resources/kafka-source-offset-version-2.1.0.txt similarity index 100% rename from sql/core/src/test/resources/structured-streaming/kafka-source-offset-version-2.1.0.txt rename to external/kafka-0-10-sql/src/test/resources/kafka-source-offset-version-2.1.0.txt diff --git a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceOffsetSuite.scala b/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceOffsetSuite.scala index c8326ffcc7ad4..22668fd6faaa9 100644 --- a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceOffsetSuite.scala +++ b/external/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) } }