Test Result : KafkaMicroBatchV2SourceSuite

0 failures (-6)
52 tests (±0)
Took 6 min 22 sec.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets3.2 secPassed
0 (SPARK-19517)2.2 secPassed
46.3 secPassed
Kafka column types1.8 secPassed
KafkaSource with watermark4.6 secPassed
Max should not overflow integer during end offset calculation6 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in10 secFixed
SPARK-27494: read kafka record containing null key/values2.9 secPassed
SPARK-30656: minPartitions4 secPassed
V2 Source is used by default2.3 secPassed
assign from earliest offsets (failOnDataLoss: false)7.8 secFixed
assign from earliest offsets (failOnDataLoss: true)3.8 secPassed
assign from latest offsets (failOnDataLoss: false)9.8 secPassed
assign from latest offsets (failOnDataLoss: true)4.9 secPassed
assign from specific offsets (failOnDataLoss: false)3.8 secFixed
assign from specific offsets (failOnDataLoss: true)2.8 secPassed
assign from specific timestamps (failOnDataLoss: false)3.9 secPassed
assign from specific timestamps (failOnDataLoss: true)3.4 secPassed
bad source options0.11 secPassed
cannot stop Kafka stream2.3 secPassed
delete a topic when a Spark job is running18 secFixed
deserialization of initial offset written by future version2.9 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics41 secPassed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)0.78 secPassed
get offsets from case insensitive parameters1 msPassed
id override5.4 secFixed
id prefix7 secFixed
input row metrics3 secPassed
maxOffsetsPerTrigger12 secPassed
minPartitions is supported0.76 secPassed
read Kafka transactional messages: read_committed25 secPassed
read Kafka transactional messages: read_uncommitted19 secPassed
reset should reset all fields4.7 secPassed
subscribe topic by pattern with topic recreation between batches6.1 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)6.9 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)9.1 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)7.2 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)13 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)6.4 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)5.7 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)11 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)7.7 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)5.2 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)6.7 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)6 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)13 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)3.8 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)3.9 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)6.5 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)5.5 secPassed
subscribing topic by pattern with topic deletions28 secPassed
unsupported kafka configs17 msPassed