Test Result : KafkaMicroBatchV2SourceSuite

0 failures (±0)
42 tests (-10)
Took 5 min 13 sec.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets3.1 secPassed
0 (SPARK-19517)7.9 secPassed
Kafka column types4.5 secPassed
KafkaSource with watermark3.7 secPassed
Max should not overflow integer during end offset calculation7.7 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in19 secPassed
SPARK-27494: read kafka record containing null key/values2.1 secPassed
V2 Source is used by default1.5 secPassed
assign from earliest offsets (failOnDataLoss: false)3.8 secPassed
assign from earliest offsets (failOnDataLoss: true)6.4 secPassed
assign from latest offsets (failOnDataLoss: false)10 secPassed
assign from latest offsets (failOnDataLoss: true)5.2 secPassed
assign from specific offsets (failOnDataLoss: false)6 secPassed
assign from specific offsets (failOnDataLoss: true)4.5 secPassed
bad source options16 msPassed
cannot stop Kafka stream2 secPassed
delete a topic when a Spark job is running10 secPassed
deserialization of initial offset written by future version0.67 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics17 secPassed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)1.4 secPassed
get offsets from case insensitive parameters1 msPassed
input row metrics4.8 secPassed
maxOffsetsPerTrigger24 secPassed
minPartitions is supported1.1 secPassed
read Kafka transactional messages: read_committed23 secPassed
read Kafka transactional messages: read_uncommitted17 secPassed
reset should reset all fields7.5 secPassed
subscribe topic by pattern with topic recreation between batches8.8 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)7.1 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)6.3 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)6.8 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)14 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)10 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)3.6 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)6.7 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)6.2 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)6.5 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)5.7 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)5.9 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)6.9 secPassed
subscribing topic by pattern with topic deletions19 secPassed
unsupported kafka configs20 msPassed