Test Result : KafkaMicroBatchV2SourceSuite

0 failures (-5)
52 tests (±0)
Took 4 min 34 sec.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets2.6 secPassed
0 (SPARK-19517)2.7 secPassed
42.4 secFixed
Kafka column types2 secPassed
KafkaSource with watermark2.3 secPassed
Max should not overflow integer during end offset calculation5.4 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in19 secPassed
SPARK-27494: read kafka record containing null key/values2.3 secPassed
SPARK-30656: minPartitions1.6 secPassed
V2 Source is used by default0.67 secPassed
assign from earliest offsets (failOnDataLoss: false)2.7 secPassed
assign from earliest offsets (failOnDataLoss: true)2.4 secPassed
assign from latest offsets (failOnDataLoss: false)2.8 secPassed
assign from latest offsets (failOnDataLoss: true)2.7 secPassed
assign from specific offsets (failOnDataLoss: false)2.7 secPassed
assign from specific offsets (failOnDataLoss: true)1.7 secPassed
assign from specific timestamps (failOnDataLoss: false)2.6 secPassed
assign from specific timestamps (failOnDataLoss: true)2.5 secPassed
bad source options28 msPassed
cannot stop Kafka stream1.4 secPassed
delete a topic when a Spark job is running12 secPassed
deserialization of initial offset written by future version0.64 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics24 secPassed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)0.83 secPassed
get offsets from case insensitive parameters1 msPassed
id override2.8 secPassed
id prefix3.3 secPassed
input row metrics2.1 secPassed
maxOffsetsPerTrigger19 secPassed
minPartitions is supported0.26 secPassed
read Kafka transactional messages: read_committed20 secPassed
read Kafka transactional messages: read_uncommitted11 secFixed
reset should reset all fields2.6 secFixed
subscribe topic by pattern with topic recreation between batches6.1 secFixed
subscribing topic by name from earliest offsets (failOnDataLoss: false)3.1 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)3.1 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)3.8 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)3.8 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)2.3 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)2.5 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)4 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)3 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)13 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)3.9 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)7.3 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)4.6 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)5.4 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)3.8 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)10 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)3.6 secPassed
subscribing topic by pattern with topic deletions25 secFixed
unsupported kafka configs18 msPassed