Test Result : StateStoreSuite

0 failures (±0)
75 tests (±0)
Took 12 sec.

All Tests

Test nameDurationStatus
SPARK-18342: commit fails when rename fails21 msPassed
SPARK-18416: do not create temp delta file until the store is updated0.2 secPassed
SPARK-19677: Committing a delta file atop an existing one should not fail on HDFS32 msPassed
SPARK-21145: Restarted queries create new provider instances0.72 secPassed
SPARK-34270: StateStoreMetrics.combine should not override individual metrics6 msPassed
SPARK-35659: StateStore.put cannot put null value30 msPassed
SPARK-35763: StateStoreCustomMetric withNewDesc and createSQLMetric55 msPassed
StateStore.get0.18 secPassed
abort - with codec lz477 msPassed
abort - with codec lzf80 msPassed
abort - with codec org.apache.spark.io.LZ4CompressionCodec83 msPassed
abort - with codec org.apache.spark.io.LZFCompressionCodec80 msPassed
abort - with codec org.apache.spark.io.SnappyCompressionCodec87 msPassed
abort - with codec org.apache.spark.io.ZStdCompressionCodec82 msPassed
abort - with codec snappy86 msPassed
abort - with codec zstd88 msPassed
cleaning1 secPassed
corrupted file handling0.42 secPassed
error writing [version].delta cancels the output stream0.1 secPassed
expose metrics with custom metrics to StateStoreMetrics84 msPassed
failure after committing with MAX_BATCHES_TO_RETAIN_IN_MEMORY set to 10.2 secPassed
get, put, remove, commit, and all data iterator - with codec lz40.19 secPassed
get, put, remove, commit, and all data iterator - with codec lzf0.18 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.LZ4CompressionCodec0.16 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.LZFCompressionCodec0.18 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.SnappyCompressionCodec0.15 secPassed
get, put, remove, commit, and all data iterator - with codec org.apache.spark.io.ZStdCompressionCodec0.16 secPassed
get, put, remove, commit, and all data iterator - with codec snappy0.18 secPassed
get, put, remove, commit, and all data iterator - with codec zstd0.2 secPassed
getStore with invalid versions - with codec lz40.12 secPassed
getStore with invalid versions - with codec lzf0.1 secPassed
getStore with invalid versions - with codec org.apache.spark.io.LZ4CompressionCodec0.1 secPassed
getStore with invalid versions - with codec org.apache.spark.io.LZFCompressionCodec83 msPassed
getStore with invalid versions - with codec org.apache.spark.io.SnappyCompressionCodec83 msPassed
getStore with invalid versions - with codec org.apache.spark.io.ZStdCompressionCodec0.12 secPassed
getStore with invalid versions - with codec snappy82 msPassed
getStore with invalid versions - with codec zstd95 msPassed
maintenance1.7 secPassed
no cache data with MAX_BATCHES_TO_RETAIN_IN_MEMORY set to 00.11 secPassed
numKeys metrics - with codec lz40.13 secPassed
numKeys metrics - with codec lzf0.12 secPassed
numKeys metrics - with codec org.apache.spark.io.LZ4CompressionCodec0.13 secPassed
numKeys metrics - with codec org.apache.spark.io.LZFCompressionCodec0.12 secPassed
numKeys metrics - with codec org.apache.spark.io.SnappyCompressionCodec0.1 secPassed
numKeys metrics - with codec org.apache.spark.io.ZStdCompressionCodec0.14 secPassed
numKeys metrics - with codec snappy0.13 secPassed
numKeys metrics - with codec zstd0.13 secPassed
prefix scan - with codec lz444 msPassed
prefix scan - with codec lzf37 msPassed
prefix scan - with codec org.apache.spark.io.LZ4CompressionCodec34 msPassed
prefix scan - with codec org.apache.spark.io.LZFCompressionCodec39 msPassed
prefix scan - with codec org.apache.spark.io.SnappyCompressionCodec37 msPassed
prefix scan - with codec org.apache.spark.io.ZStdCompressionCodec40 msPassed
prefix scan - with codec snappy38 msPassed
prefix scan - with codec zstd36 msPassed
removing while iterating - with codec lz443 msPassed
removing while iterating - with codec lzf40 msPassed
removing while iterating - with codec org.apache.spark.io.LZ4CompressionCodec30 msPassed
removing while iterating - with codec org.apache.spark.io.LZFCompressionCodec34 msPassed
removing while iterating - with codec org.apache.spark.io.SnappyCompressionCodec37 msPassed
removing while iterating - with codec org.apache.spark.io.ZStdCompressionCodec38 msPassed
removing while iterating - with codec snappy32 msPassed
removing while iterating - with codec zstd28 msPassed
reports memory usage57 msPassed
reports memory usage on current version53 msPassed
retaining only two latest versions when MAX_BATCHES_TO_RETAIN_IN_MEMORY set to 20.21 secPassed
snapshotting1.1 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec lz40.15 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec lzf0.13 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.LZ4CompressionCodec0.13 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.LZFCompressionCodec0.13 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.SnappyCompressionCodec0.11 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec org.apache.spark.io.ZStdCompressionCodec0.13 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec snappy0.14 secPassed
two concurrent StateStores - one for read-only and one for read-write - with codec zstd0.13 secPassed