Test Result : StreamSuite

0 failures (±0)
57 tests (±0)
Took 41 sec.

All Tests

Test nameDurationStatus
1 checkpoint2 secPassed
8)33 msPassed
8+)42 msPassed
DataFrame reuse8.3 secPassed
SPARK-19065: dropDuplicates should not create expressions using the same id0.55 secPassed
SPARK-19873: streaming aggregation with change in number of partitions1.1 secPassed
SPARK-20432: union one stream with itself3.2 secPassed
SPARK-26379 Structured Streaming - Exception on adding current_timestamp to Dataset - use v1 sink1.4 secPassed
SPARK-26379 Structured Streaming - Exception on adding current_timestamp to Dataset - use v2 sink1.3 secPassed
SPARK-30143: stop waits until timeout if blocked - trigger: ContinuousTrigger(1000)2 secPassed
SPARK-30143: stop waits until timeout if blocked - trigger: ProcessingTimeTrigger(1000)2 secPassed
SPARK-30657: streaming limit after streaming dedup in append mode0.52 secPassed
SPARK-30657: streaming limit optimization from StreamingLocalLimitExec to LocalLimitExec1.7 secPassed
SPARK-30657: streaming limit should not apply on limits on state subplans0.49 secPassed
SPARK-30658: streaming limit before agg in complete mode1.2 secPassed
SPARK-30658: streaming limits before and after agg in complete mode (after limit < before limit)0.83 secPassed
SPARK-30658: streaming limits before and after agg in complete mode (before limit < after limit)0.72 secPassed
Within the same streaming query, one StreamingRelation should only be transformed to one StreamingExecutionRelation0.17 secPassed
batch id is updated correctly in the job description0.4 secPassed
calling stop() on a query cancels related jobs0.14 secPassed
codegen-continuous85 msPassed
codegen-microbatch1.9 secPassed
computeStats7 msPassed
computeStats2 msPassed
computeStats14 msPassed
custom state store provider read from offset log0.79 secPassed
explain0.53 secPassed
explain - redaction0.7 secPassed
explain join with MemoryStream75 msPassed
explain join with a normal source0.14 secPassed
explain-continuous0.2 secPassed
handle fatal errors thrown from the stream thread0.12 secPassed
insert an extraStrategy0.24 secPassed
is_continuous_processing property should be false for microbatch processing0.19 secPassed
is_continuous_processing property should be true for continuous processing2.5 secPassed
join0.45 secPassed
map with recovery0.43 secPassed
minimize delay between batch construction and execution0.31 secPassed
output mode API in Scala1 msPassed
should resolve the checkpoint path29 msPassed
specify custom state store provider0.28 secPassed
sql queries0.17 secPassed
streaming limit in multiple partitions0.46 secPassed
streaming limit in multiple partitions by column0.44 secPassed
streaming limit in update mode5 msPassed
streaming limit with multiple limits0.85 secPassed
streaming limit with other operators0.56 secPassed
streaming limit with state0.6 secPassed
streaming limit without state0.37 secPassed
union two streams0.44 secPassed
unsupported queries58 msPassed
view ClosedByInterruptException as a normal query stop42 msPassed
view ExecutionException as a normal query stop37 msPassed
view InterruptedException as a normal query stop41 msPassed
view InterruptedIOException as a normal query stop39 msPassed
view UncheckedExecutionException as a normal query stop40 msPassed
view UncheckedIOException as a normal query stop46 msPassed