Test Result : StreamSuite

0 failures (±0)
57 tests (±0)
Took 1 min 23 sec.

All Tests

Test nameDurationStatus
1 checkpoint3.8 secPassed
8)96 msPassed
8+)45 msPassed
DataFrame reuse21 secPassed
SPARK-19065: dropDuplicates should not create expressions using the same id1 secPassed
SPARK-19873: streaming aggregation with change in number of partitions1.7 secPassed
SPARK-20432: union one stream with itself5.7 secPassed
SPARK-26379 Structured Streaming - Exception on adding current_timestamp to Dataset - use v1 sink2.1 secPassed
SPARK-26379 Structured Streaming - Exception on adding current_timestamp to Dataset - use v2 sink2.1 secPassed
SPARK-30143: stop waits until timeout if blocked - trigger: ContinuousTrigger(1000)3.7 secPassed
SPARK-30143: stop waits until timeout if blocked - trigger: ProcessingTimeTrigger(1000)2.8 secPassed
SPARK-30657: streaming limit after streaming dedup in append mode0.9 secPassed
SPARK-30657: streaming limit optimization from StreamingLocalLimitExec to LocalLimitExec3.1 secPassed
SPARK-30657: streaming limit should not apply on limits on state subplans0.83 secPassed
SPARK-30658: streaming limit before agg in complete mode2 secPassed
SPARK-30658: streaming limits before and after agg in complete mode (after limit < before limit)1.7 secPassed
SPARK-30658: streaming limits before and after agg in complete mode (before limit < after limit)2.6 secPassed
Within the same streaming query, one StreamingRelation should only be transformed to one StreamingExecutionRelation0.51 secPassed
batch id is updated correctly in the job description0.76 secPassed
calling stop() on a query cancels related jobs0.4 secPassed
codegen-continuous0.14 secPassed
codegen-microbatch1.1 secPassed
computeStats6 msPassed
computeStats2 msPassed
computeStats0.11 secPassed
custom state store provider read from offset log1.5 secPassed
explain0.82 secPassed
explain - redaction0.88 secPassed
explain join with MemoryStream0.1 secPassed
explain join with a normal source0.14 secPassed
explain-continuous0.24 secPassed
handle fatal errors thrown from the stream thread0.74 secPassed
insert an extraStrategy0.6 secPassed
is_continuous_processing property should be false for microbatch processing0.52 secPassed
is_continuous_processing property should be true for continuous processing3.2 secPassed
join0.53 secPassed
map with recovery0.46 secPassed
minimize delay between batch construction and execution0.58 secPassed
output mode API in Scala0 msPassed
should resolve the checkpoint path60 msPassed
specify custom state store provider0.39 secPassed
sql queries0.48 secPassed
streaming limit in multiple partitions2.3 secPassed
streaming limit in multiple partitions by column4.1 secPassed
streaming limit in update mode8 msPassed
streaming limit with multiple limits1.6 secPassed
streaming limit with other operators0.94 secPassed
streaming limit with state1.6 secPassed
streaming limit without state0.49 secPassed
union two streams0.76 secPassed
unsupported queries80 msPassed
view ClosedByInterruptException as a normal query stop0.15 secPassed
view ExecutionException as a normal query stop0.15 secPassed
view InterruptedException as a normal query stop0.16 secPassed
view InterruptedIOException as a normal query stop0.15 secPassed
view UncheckedExecutionException as a normal query stop0.15 secPassed
view UncheckedIOException as a normal query stop87 msPassed