Test Result : KafkaMicroBatchV2SourceSuite

0 failures (-16)
52 tests (±0)
Took 8 min 54 sec.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets3.1 secPassed
0 (SPARK-19517)5 secFixed
412 secFixed
Kafka column types3 secPassed
KafkaSource with watermark2.6 secFixed
Max should not overflow integer during end offset calculation4 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in34 secFixed
SPARK-27494: read kafka record containing null key/values5.8 secFixed
SPARK-30656: minPartitions12 secFixed
V2 Source is used by default2.6 secFixed
assign from earliest offsets (failOnDataLoss: false)5.4 secPassed
assign from earliest offsets (failOnDataLoss: true)7.7 secPassed
assign from latest offsets (failOnDataLoss: false)9.5 secPassed
assign from latest offsets (failOnDataLoss: true)9.2 secPassed
assign from specific offsets (failOnDataLoss: false)4.4 secPassed
assign from specific offsets (failOnDataLoss: true)4.3 secPassed
assign from specific timestamps (failOnDataLoss: false)6.1 secPassed
assign from specific timestamps (failOnDataLoss: true)10 secPassed
bad source options11 msPassed
cannot stop Kafka stream2.7 secPassed
delete a topic when a Spark job is running11 secFixed
deserialization of initial offset written by future version3.2 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics47 secFixed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)1.1 secPassed
get offsets from case insensitive parameters0 msPassed
id override8.5 secFixed
id prefix5.4 secFixed
input row metrics5 secPassed
maxOffsetsPerTrigger31 secPassed
minPartitions is supported1.4 secFixed
read Kafka transactional messages: read_committed47 secFixed
read Kafka transactional messages: read_uncommitted24 secFixed
reset should reset all fields15 secFixed
subscribe topic by pattern with topic recreation between batches8.2 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)10 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)13 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)10 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)13 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)4.9 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)5.4 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)8.7 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)9.3 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)8.1 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)7.7 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)9.8 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)12 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)9.2 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)3.9 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)9.7 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)10 secPassed
subscribing topic by pattern with topic deletions30 secFixed
unsupported kafka configs14 msPassed