Test Result : FlatMapGroupsWithStateSuite

0 failures
81 tests
Took 12 sec.

All Tests

Test nameDurationStatus
GroupState - get, exists, update, remove2 msPassed
GroupState - getCurrentProcessingTimeMs1 msPassed
GroupState - getCurrentWatermarkMs1 msPassed
GroupState - hasTimedOut1 msPassed
GroupState - illegal params to setTimeout3 msPassed
GroupState - primitive type1 msPassed
GroupState - setTimeout - with EventTimeTimeout1 msPassed
GroupState - setTimeout - with NoTimeout3 msPassed
GroupState - setTimeout - with ProcessingTimeTimeout1 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - no update7 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - setting timeout with state removal not allowed8 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - setting timeout without init state not allowed7 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - state and timeout timestamp updated8 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - state removed7 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - state updated7 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - timeout timestamp updated to before watermark9 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - no update8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - setting timeout with state removal not allowed8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - state and timeout timestamp updated7 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - state removed8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - state updated8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - timeout timestamp updated to before watermark8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - no update8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - setting timeout with state removal not allowed8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - state and timeout timestamp updated8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - state removed8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - state updated8 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - timeout timestamp updated to before watermark8 msPassed
InputProcessor - process new data - NoTimeout - no prior state - no update24 msPassed
InputProcessor - process new data - NoTimeout - no prior state - state removed7 msPassed
InputProcessor - process new data - NoTimeout - no prior state - state updated16 msPassed
InputProcessor - process new data - NoTimeout - prior state set - no update7 msPassed
InputProcessor - process new data - NoTimeout - prior state set - state removed9 msPassed
InputProcessor - process new data - NoTimeout - prior state set - state updated8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - no update7 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - state and timeout duration updated8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - state removed7 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - state updated13 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - timeout updated after state removed7 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - timeout updated without initializing state8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - no update8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - state and timeout duration updated8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - state removed8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - state updated7 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - timeout updated after state removed8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - no update8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - state and timeout duration updated7 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - state removed8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - state updated8 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - timeout updated after state removed8 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should not timeout7 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - no update/remove7 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - remove state7 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - timeout and state updated7 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - timeout timestamp updated7 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - update state8 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should not timeout10 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - no update/remove8 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - remove state8 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - timeout duration and state updated7 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - timeout duration updated8 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - update state7 msPassed
SPARK-20714: watermark does not fail query when timeout = NoTimeout0.21 secPassed
SPARK-20714: watermark does not fail query when timeout = ProcessingTimeTimeout0.24 secPassed
StateStore.abort on task failure handling0.69 secPassed
disallow complete mode8 msPassed
flatMapGroupsWithState - batch0.15 secPassed
flatMapGroupsWithState - recovery from checkpoint uses state format version 10.51 secPassed
flatMapGroupsWithState - streaming + aggregation - state format version 11.4 secPassed
flatMapGroupsWithState - streaming + aggregation - state format version 21.4 secPassed
flatMapGroupsWithState - streaming + func returns iterator that updates state lazily0.52 secPassed
flatMapGroupsWithState - streaming - state format version 10.77 secPassed
flatMapGroupsWithState - streaming - state format version 20.69 secPassed
flatMapGroupsWithState - streaming w/ event time timeout + watermark - state format version 11 secPassed
flatMapGroupsWithState - streaming w/ event time timeout + watermark - state format version 20.96 secPassed
flatMapGroupsWithState - streaming with processing time timeout - state format version 10.76 secPassed
flatMapGroupsWithState - streaming with processing time timeout - state format version 20.86 secPassed
flatMapGroupsWithState - uses state format version 2 by default0.23 secPassed
mapGroupsWithState - batch0.19 secPassed
mapGroupsWithState - streaming0.76 secPassed
output partitioning is unknown0.2 secPassed