Test Result : KafkaMicroBatchV2SourceSuite

0 failures (±0) , 1 skipped (±0)
52 tests (±0)
Took 2 min 53 sec.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets0.27 secPassed
Kafka column types1.2 secPassed
KafkaSource with watermark2 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in2.2 secPassed
SPARK-25495: FetchedData.reset should reset all fields1.7 secPassed
SPARK-26718 Rate limit set to Long.Max should not overflow integer during end offset calculation0.97 secPassed
SPARK-27494: read kafka record containing null key/values.1 secPassed
SPARK-30656: minPartitions2.4 secPassed
V2 Source is used by default0.27 secPassed
allow group.id override1.3 secPassed
allow group.id prefix1.3 secPassed
assign from earliest offsets (failOnDataLoss: false)5 secPassed
assign from earliest offsets (failOnDataLoss: true)4.6 secPassed
assign from latest offsets (failOnDataLoss: false)4.1 secPassed
assign from latest offsets (failOnDataLoss: true)5.5 secPassed
assign from specific offsets (failOnDataLoss: false)3.1 secPassed
assign from specific offsets (failOnDataLoss: true)2.7 secPassed
assign from specific timestamps (failOnDataLoss: false)4.8 secPassed
assign from specific timestamps (failOnDataLoss: true)5 secPassed
bad source options16 msPassed
cannot stop Kafka stream0.99 secPassed
default config of includeHeader doesn't break existing query from Spark 2.42.1 secPassed
delete a topic when a Spark job is running3.7 secPassed
deserialization of initial offset written by Spark 2.1.0 (SPARK-19517)1.9 secPassed
deserialization of initial offset written by future version0.17 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics7.9 secPassed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)0.24 secPassed
get offsets from case insensitive parameters2 msPassed
input row metrics1 secPassed
maxOffsetsPerTrigger4.9 secPassed
minPartitions is supported58 msPassed
read Kafka transactional messages: read_committed13 secPassed
read Kafka transactional messages: read_uncommitted8.8 secPassed
subscribe topic by pattern with topic recreation between batches3.1 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)6.3 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)5.4 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)6 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)5.4 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)3.3 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)2.7 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)4.9 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)5 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)4.5 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)5.1 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)5.4 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)5.5 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)2.6 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)2.7 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)5 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)3.9 secPassed
subscribing topic by pattern with topic deletions0 msSkipped
unsupported kafka configs17 msPassed