Test Result : StateStoreSuite

0 failures
65 tests
Took 8 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 HDFS31 msPassed
SPARK-21145: Restarted queries create new provider instances0.6 secPassed
SPARK-34270: StateStoreMetrics.combine should not override individual metrics5 msPassed
StateStore.get76 msPassed
abort - with codec lz446 msPassed
abort - with codec lzf45 msPassed
abort - with codec org.apache.spark.io.LZ4CompressionCodec45 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.24 secPassed
error writing [version].delta cancels the output stream99 msPassed
expose metrics with custom metrics to StateStoreMetrics94 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.19 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.LZFCompressionCodec0.19 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.SnappyCompressionCodec0.19 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.2 secPassed
get, put, remove, commit, and all data iterator - with codec zstd0.21 secPassed
getStore with invalid versions - with codec lz457 msPassed
getStore with invalid versions - with codec lzf57 msPassed
getStore with invalid versions - with codec org.apache.spark.io.LZ4CompressionCodec58 msPassed
getStore with invalid versions - with codec org.apache.spark.io.LZFCompressionCodec56 msPassed
getStore with invalid versions - with codec org.apache.spark.io.SnappyCompressionCodec57 msPassed
getStore with invalid versions - with codec org.apache.spark.io.ZStdCompressionCodec57 msPassed
getStore with invalid versions - with codec snappy58 msPassed
getStore with invalid versions - with codec zstd56 msPassed
maintenance0.92 secPassed
no cache data with MAX_BATCHES_TO_RETAIN_IN_MEMORY set to 096 msPassed
numKeys metrics - with codec lz499 msPassed
numKeys metrics - with codec lzf0.14 secPassed
numKeys metrics - with codec org.apache.spark.io.LZ4CompressionCodec95 msPassed
numKeys metrics - with codec org.apache.spark.io.LZFCompressionCodec93 msPassed
numKeys metrics - with codec org.apache.spark.io.SnappyCompressionCodec95 msPassed
numKeys metrics - with codec org.apache.spark.io.ZStdCompressionCodec93 msPassed
numKeys metrics - with codec snappy97 msPassed
numKeys metrics - with codec zstd95 msPassed
removing while iterating - with codec lz449 msPassed
removing while iterating - with codec lzf47 msPassed
removing while iterating - with codec org.apache.spark.io.LZ4CompressionCodec48 msPassed
removing while iterating - with codec org.apache.spark.io.LZFCompressionCodec47 msPassed
removing while iterating - with codec org.apache.spark.io.SnappyCompressionCodec47 msPassed
removing while iterating - with codec org.apache.spark.io.ZStdCompressionCodec47 msPassed
removing while iterating - with codec snappy48 msPassed
removing while iterating - with codec zstd47 msPassed
reports memory usage39 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.54 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec lz496 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.LZ4CompressionCodec94 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.LZFCompressionCodec95 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.SnappyCompressionCodec96 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.ZStdCompressionCodec95 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec snappy95 msPassed
two concurrent StateStores - one for read-only and one for read-write - with codec zstd94 msPassed