Skip to content

Commit f86bd3f

Browse files
committed
Remove checks for tmp dirs
1 parent 160147f commit f86bd3f

File tree

1 file changed

+0
-9
lines changed

1 file changed

+0
-9
lines changed

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

-9
Original file line numberDiff line numberDiff line change
@@ -246,18 +246,9 @@ class RocksDBStateStoreIntegrationSuite extends StreamTest
246246
inputData.addData(2, 3)
247247
query.processAllAvailable()
248248

249-
// StateStore should be unloaded, so its tmp dir shouldn't exist
250-
for (file <- new File(Utils.getLocalDir(sparkConf)).listFiles()) {
251-
assert(!file.getName().startsWith("StateStore"))
252-
}
253-
254249
inputData.addData(3, 4)
255250
inputData.addData(4, 5)
256251
query.processAllAvailable()
257-
258-
for (file <- new File(Utils.getLocalDir(sparkConf)).listFiles()) {
259-
assert(!file.getName().startsWith("StateStore"))
260-
}
261252
} finally {
262253
query.stop()
263254
}

0 commit comments

Comments
 (0)