Test Result : StreamSuite

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

All Tests

Test nameDurationStatus
1 checkpoint3.4 secPassed
8)29 msPassed
8+)22 msPassed
DataFrame reuse10 secPassed
SPARK-19065: dropDuplicates should not create expressions using the same id0.55 secPassed
SPARK-19873: streaming aggregation with change in number of partitions1 secPassed
SPARK-20432: union one stream with itself3 secPassed
SPARK-26379 Structured Streaming - Exception on adding current_timestamp to Dataset - use v1 sink1.1 secPassed
SPARK-26379 Structured Streaming - Exception on adding current_timestamp to Dataset - use v2 sink1.2 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 mode1.8 secPassed
SPARK-30657: streaming limit optimization from StreamingLocalLimitExec to LocalLimitExec5 secPassed
SPARK-30657: streaming limit should not apply on limits on state subplans1.1 secPassed
SPARK-30658: streaming limit before agg in complete mode1 secPassed
SPARK-30658: streaming limits before and after agg in complete mode (after limit < before limit)0.65 secPassed
SPARK-30658: streaming limits before and after agg in complete mode (before limit < after limit)1.5 secPassed
Within the same streaming query, one StreamingRelation should only be transformed to one StreamingExecutionRelation41 msPassed
batch id is updated correctly in the job description0.24 secPassed
calling stop() on a query cancels related jobs77 msPassed
codegen-continuous71 msPassed
codegen-microbatch1.8 secPassed
computeStats11 msPassed
computeStats1 msPassed
computeStats4 msPassed
custom state store provider read from offset log0.72 secPassed
explain0.46 secPassed
explain - redaction0.5 secPassed
explain join with MemoryStream72 msPassed
explain join with a normal source96 msPassed
explain-continuous0.1 secPassed
handle fatal errors thrown from the stream thread0.1 secPassed
insert an extraStrategy0.13 secPassed
is_continuous_processing property should be false for microbatch processing0.14 secPassed
is_continuous_processing property should be true for continuous processing2.9 secPassed
join0.28 secPassed
map with recovery0.33 secPassed
minimize delay between batch construction and execution0.35 secPassed
output mode API in Scala0 msPassed
should resolve the checkpoint path25 msPassed
specify custom state store provider0.19 secPassed
sql queries0.14 secPassed
streaming limit in multiple partitions1.1 secPassed
streaming limit in multiple partitions by column0.3 secPassed
streaming limit in update mode4 msPassed
streaming limit with multiple limits0.55 secPassed
streaming limit with other operators0.45 secPassed
streaming limit with state0.48 secPassed
streaming limit without state0.27 secPassed
union two streams0.31 secPassed
unsupported queries40 msPassed
view ClosedByInterruptException as a normal query stop28 msPassed
view ExecutionException as a normal query stop27 msPassed
view InterruptedException as a normal query stop30 msPassed
view InterruptedIOException as a normal query stop28 msPassed
view UncheckedExecutionException as a normal query stop29 msPassed
view UncheckedIOException as a normal query stop41 msPassed