Test Result : KafkaMicroBatchV2SourceSuite

0 failures (±0) , 1 skipped (+1)
52 tests (+10)
Took 6 min 41 sec.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets2 secPassed
0 (SPARK-19517)2.6 secPassed
44.9 secPassed
Kafka column types1.7 secPassed
KafkaSource with watermark5.9 secPassed
Max should not overflow integer during end offset calculation2.6 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in13 secPassed
SPARK-27494: read kafka record containing null key/values3.4 secPassed
SPARK-30656: minPartitions9.1 secPassed
V2 Source is used by default3.6 secPassed
assign from earliest offsets (failOnDataLoss: false)9.1 secPassed
assign from earliest offsets (failOnDataLoss: true)7 secPassed
assign from latest offsets (failOnDataLoss: false)6.3 secPassed
assign from latest offsets (failOnDataLoss: true)15 secPassed
assign from specific offsets (failOnDataLoss: false)3.8 secPassed
assign from specific offsets (failOnDataLoss: true)7.2 secPassed
assign from specific timestamps (failOnDataLoss: false)7.8 secPassed
assign from specific timestamps (failOnDataLoss: true)5 secPassed
bad source options13 msPassed
cannot stop Kafka stream6.3 secPassed
delete a topic when a Spark job is running17 secPassed
deserialization of initial offset written by future version0.63 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics32 secPassed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)1.5 secPassed
get offsets from case insensitive parameters1 msPassed
id override3.7 secPassed
id prefix7.8 secPassed
input row metrics9 secPassed
maxOffsetsPerTrigger20 secPassed
minPartitions is supported0.41 secPassed
read Kafka transactional messages: read_committed28 secPassed
read Kafka transactional messages: read_uncommitted15 secPassed
reset should reset all fields4.8 secPassed
subscribe topic by pattern with topic recreation between batches17 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)7 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)9 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)7.8 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)10 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)7.6 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)5.1 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)7.7 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)8.7 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)6.7 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)9.8 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)7.6 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)6.8 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)6.3 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)6.4 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)9.3 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)6.6 secPassed
subscribing topic by pattern with topic deletions-1 msSkipped
unsupported kafka configs19 msPassed