Skip to content

Commit a166196

Browse files
brkyvzzsxwing
authored andcommitted
[SPARK-17569][SPARK-17569][TEST] Make the unit test added for work again
## What changes were proposed in this pull request? A [PR](a6aade0) was merged concurrently that made the unit test for PR #15122 not test anything anymore. This PR fixes the test. ## How was this patch tested? Changed line https://github.com/apache/spark/blob/0d634875026ccf1eaf984996e9460d7673561f80/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala#L137 from `false` to `true` and made sure the unit test failed. Author: Burak Yavuz <[email protected]> Closes #15203 from brkyvz/fix-test.
1 parent f4f6bd8 commit a166196

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/FileStreamSourceSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ class FileStreamSourceSuite extends SparkFunSuite with SharedSQLContext {
9292
val dir = new File(temp, "dir") // use non-existent directory to test whether log make the dir
9393
val metadataLog =
9494
new FileStreamSourceLog(FileStreamSourceLog.VERSION, spark, dir.getAbsolutePath)
95-
assert(metadataLog.add(0, Array(FileEntry(s"$scheme:///file1", 100L))))
95+
assert(metadataLog.add(0, Array(FileEntry(s"$scheme:///file1", 100L, 0))))
9696

9797
val newSource = new FileStreamSource(spark, s"$scheme:///", "parquet", StructType(Nil),
9898
dir.getAbsolutePath, Map.empty)

0 commit comments

Comments
 (0)