diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/FileStreamSourceSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/FileStreamSourceSuite.scala index 25ce70e1167b5..206ec1cd0af2c 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/streaming/FileStreamSourceSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/streaming/FileStreamSourceSuite.scala @@ -890,6 +890,7 @@ class FileStreamSourceSuite extends FileStreamSourceTest { List("keep2", "keep3")) assert(fileSource.getBatch(Some(LongOffset(1)), LongOffset(2)).as[String].collect() === List("keep3")) + true } ) }