Test Result : StateStoreSuite

0 failures
65 tests
Took 8.2 sec.

All Tests

Test nameDurationStatus
SPARK-18342: commit fails when rename fails25 msPassed
SPARK-18416: do not create temp delta file until the store is updated98 msPassed
SPARK-19677: Committing a delta file atop an existing one should not fail on HDFS32 msPassed
SPARK-21145: Restarted queries create new provider instances0.63 secPassed
SPARK-34270: StateStoreMetrics.combine should not override individual metrics4 msPassed
StateStore.get77 msPassed
abort - with codec lz446 msPassed
abort - with codec lzf45 msPassed
abort - with codec org.apache.spark.io.LZ4CompressionCodec46 msPassed
abort - with codec org.apache.spark.io.LZFCompressionCodec46 msPassed
abort - with codec org.apache.spark.io.SnappyCompressionCodec46 msPassed
abort - with codec org.apache.spark.io.ZStdCompressionCodec46 msPassed
abort - with codec snappy46 msPassed
abort - with codec zstd46 msPassed
cleaning0.47 secPassed
corrupted file handling0.25 secPassed
error writing [version].delta cancels the output stream99 msPassed
expose metrics with custom metrics to StateStoreMetrics98 msPassed
failure after committing with MAX_BATCHES_TO_RETAIN_IN_MEMORY set to 10.13 secPassed
get, put, remove, commit, and all data iterator - with codec lz40.21 secPassed
get, put, remove, commit, and all data iterator - with codec lzf0.21 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.LZ4CompressionCodec0.2 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.LZFCompressionCodec0.2 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.SnappyCompressionCodec0.2 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.ZStdCompressionCodec0.19 secPassed
get, put, remove, commit, and all data iterator - with codec snappy0.21 secPassed
get, put, remove, commit, and all data iterator - with codec zstd0.22 secPassed
getStore with invalid versions - with codec lz458 msPassed
getStore with invalid versions - with codec lzf58 msPassed
getStore with invalid versions - with codec org.apache.spark.io.LZ4CompressionCodec58 msPassed
getStore with invalid versions - with codec org.apache.spark.io.LZFCompressionCodec58 msPassed
getStore with invalid versions - with codec org.apache.spark.io.SnappyCompressionCodec58 msPassed
getStore with invalid versions - with codec org.apache.spark.io.ZStdCompressionCodec58 msPassed
getStore with invalid versions - with codec snappy59 msPassed
getStore with invalid versions - with codec zstd58 msPassed
maintenance0.92 secPassed
no cache data with MAX_BATCHES_TO_RETAIN_IN_MEMORY set to 098 msPassed
numKeys metrics - with codec lz497 msPassed
numKeys metrics - with codec lzf0.15 secPassed
numKeys metrics - with codec org.apache.spark.io.LZ4CompressionCodec95 msPassed
numKeys metrics - with codec org.apache.spark.io.LZFCompressionCodec94 msPassed
numKeys metrics - with codec org.apache.spark.io.SnappyCompressionCodec96 msPassed
numKeys metrics - with codec org.apache.spark.io.ZStdCompressionCodec95 msPassed
numKeys metrics - with codec snappy97 msPassed
numKeys metrics - with codec zstd96 msPassed
removing while iterating - with codec lz450 msPassed
removing while iterating - with codec lzf48 msPassed
removing while iterating - with codec org.apache.spark.io.LZ4CompressionCodec48 msPassed
removing while iterating - with codec org.apache.spark.io.LZFCompressionCodec48 msPassed
removing while iterating - with codec org.apache.spark.io.SnappyCompressionCodec48 msPassed
removing while iterating - with codec org.apache.spark.io.ZStdCompressionCodec48 msPassed
removing while iterating - with codec snappy48 msPassed
removing while iterating - with codec zstd48 msPassed
reports memory usage40 msPassed
reports memory usage on current version40 msPassed
retaining only two latest versions when MAX_BATCHES_TO_RETAIN_IN_MEMORY set to 20.13 secPassed
snapshotting0.55 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec lz498 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec lzf97 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.LZ4CompressionCodec0.1 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.LZFCompressionCodec97 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.SnappyCompressionCodec98 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.ZStdCompressionCodec97 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec snappy98 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec zstd95 msPassed