We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e0c164b commit 98b8850Copy full SHA for 98b8850
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala
@@ -527,7 +527,7 @@ private[state] class HDFSBackedStateStoreProvider(
527
528
val deltaFiles = allFiles.filter { file =>
529
file.version > snapshotFile.version && file.version <= version
530
- }
+ }.toList
531
verify(
532
deltaFiles.size == version - snapshotFile.version,
533
s"Unexpected list of delta files for version $version for $this: $deltaFiles"
0 commit comments