Test Result : FlatMapGroupsWithStateSuite

0 failures (±0)
81 tests (±0)
Took 26 sec.

All Tests

Test nameDurationStatus
GroupState - get, exists, update, remove7 msPassed
GroupState - getCurrentProcessingTimeMs2 msPassed
GroupState - getCurrentWatermarkMs3 msPassed
GroupState - hasTimedOut3 msPassed
GroupState - illegal params to setTimeout9 msPassed
GroupState - primitive type2 msPassed
GroupState - setTimeout - with EventTimeTimeout1 msPassed
GroupState - setTimeout - with NoTimeout6 msPassed
GroupState - setTimeout - with ProcessingTimeTimeout1 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - no update14 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - setting timeout with state removal not allowed12 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - setting timeout without init state not allowed13 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - state and timeout timestamp updated13 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - state removed12 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - state updated12 msPassed
InputProcessor - process new data - EventTimeTimeout - no prior state - timeout timestamp updated to before watermark17 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - no update18 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - setting timeout with state removal not allowed17 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - state and timeout timestamp updated13 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - state removed18 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - state updated18 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - timeout timestamp updated to before watermark12 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - no update16 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - setting timeout with state removal not allowed15 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - state and timeout timestamp updated19 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - state removed16 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - state updated16 msPassed
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - timeout timestamp updated to before watermark12 msPassed
InputProcessor - process new data - NoTimeout - no prior state - no update85 msPassed
InputProcessor - process new data - NoTimeout - no prior state - state removed13 msPassed
InputProcessor - process new data - NoTimeout - no prior state - state updated41 msPassed
InputProcessor - process new data - NoTimeout - prior state set - no update15 msPassed
InputProcessor - process new data - NoTimeout - prior state set - state removed17 msPassed
InputProcessor - process new data - NoTimeout - prior state set - state updated14 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - no update13 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - state and timeout duration updated15 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - state removed14 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - state updated27 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - timeout updated after state removed13 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - timeout updated without initializing state16 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - no update13 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - state and timeout duration updated19 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - state removed17 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - state updated12 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - timeout updated after state removed17 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - no update17 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - state and timeout duration updated16 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - state removed14 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - state updated17 msPassed
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - timeout updated after state removed14 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should not timeout12 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - no update/remove12 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - remove state12 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - timeout and state updated12 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - timeout timestamp updated17 msPassed
InputProcessor - process timed out state - EventTimeTimeout - should timeout - update state11 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should not timeout17 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - no update/remove15 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - remove state14 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - timeout duration and state updated13 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - timeout duration updated13 msPassed
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - update state14 msPassed
SPARK-20714: watermark does not fail query when timeout = NoTimeout0.38 secPassed
SPARK-20714: watermark does not fail query when timeout = ProcessingTimeTimeout0.42 secPassed
abort on task failure handling1 secPassed
disallow complete mode25 msPassed
flatMapGroupsWithState - batch0.39 secPassed
flatMapGroupsWithState - recovery from checkpoint uses state format version 10.81 secPassed
flatMapGroupsWithState - streaming + aggregation - state format version 13.9 secPassed
flatMapGroupsWithState - streaming + aggregation - state format version 23.9 secPassed
flatMapGroupsWithState - streaming + func returns iterator that updates state lazily1.2 secPassed
flatMapGroupsWithState - streaming - state format version 11.9 secPassed
flatMapGroupsWithState - streaming - state format version 21.3 secPassed
flatMapGroupsWithState - streaming w/ event time timeout + watermark - state format version 13.2 secPassed
flatMapGroupsWithState - streaming w/ event time timeout + watermark - state format version 21.8 secPassed
flatMapGroupsWithState - streaming with processing time timeout - state format version 11.4 secPassed
flatMapGroupsWithState - streaming with processing time timeout - state format version 21.4 secPassed
flatMapGroupsWithState - uses state format version 2 by default0.36 secPassed
mapGroupsWithState - batch0.39 secPassed
mapGroupsWithState - streaming1.3 secPassed
output partitioning is unknown0.35 secPassed