Test Result : KafkaMicroBatchV1SourceSuite

5 failures (+5)
50 tests (±0)
Took 23 min.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets3.3 secPassed
0 (SPARK-19517)8.3 secPassed
Kafka column types8.3 secPassed
KafkaSource with watermark7.3 secPassed
Max should not overflow integer during end offset calculation6.5 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in1 min 7 secPassed
SPARK-27494: read kafka record containing null key/values32 secPassed
SPARK-30656: minPartitions22 secPassed
V1 Source is used when disabled through SQLConf5.5 secPassed
assign from earliest offsets (failOnDataLoss: false)40 secRegression
assign from earliest offsets (failOnDataLoss: true)13 secPassed
assign from latest offsets (failOnDataLoss: false)1 min 13 secPassed
assign from latest offsets (failOnDataLoss: true)10 secPassed
assign from specific offsets (failOnDataLoss: false)34 secPassed
assign from specific offsets (failOnDataLoss: true)18 secPassed
assign from specific timestamps (failOnDataLoss: false)21 secPassed
assign from specific timestamps (failOnDataLoss: true)42 secPassed
bad source options19 msPassed
cannot stop Kafka stream8.8 secPassed
delete a topic when a Spark job is running14 secRegression
deserialization of initial offset written by future version1.7 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics54 secPassed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)2 secPassed
get offsets from case insensitive parameters7 msPassed
id override22 secPassed
id prefix20 secPassed
input row metrics9.4 secPassed
maxOffsetsPerTrigger59 secPassed
read Kafka transactional messages: read_committed1 min 1 secRegression
read Kafka transactional messages: read_uncommitted1 min 0 secRegression
reset should reset all fields46 secPassed
subscribe topic by pattern with topic recreation between batches18 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)57 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)33 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)44 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)49 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)37 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)23 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)23 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)19 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)23 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)22 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)32 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)16 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)10 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)42 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)26 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)57 secRegression
subscribing topic by pattern with topic deletions1 min 5 secPassed
unsupported kafka configs20 msPassed