Test Result : KafkaMicroBatchV1SourceSuite

0 failures (-2)
50 tests (±0)
Took 3 min 5 sec.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets0.79 secPassed
0 (SPARK-19517)1.4 secPassed
Kafka column types1.6 secPassed
KafkaSource with watermark2.5 secPassed
Max should not overflow integer during end offset calculation1.3 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in8.7 secPassed
SPARK-27494: read kafka record containing null key/values1.7 secPassed
SPARK-30656: minPartitions1.4 secPassed
V1 Source is used when disabled through SQLConf0.72 secPassed
assign from earliest offsets (failOnDataLoss: false)2.3 secPassed
assign from earliest offsets (failOnDataLoss: true)2.6 secPassed
assign from latest offsets (failOnDataLoss: false)2.9 secPassed
assign from latest offsets (failOnDataLoss: true)2.8 secPassed
assign from specific offsets (failOnDataLoss: false)1.7 secPassed
assign from specific offsets (failOnDataLoss: true)2.2 secPassed
assign from specific timestamps (failOnDataLoss: false)2.6 secPassed
assign from specific timestamps (failOnDataLoss: true)2.5 secPassed
bad source options16 msPassed
cannot stop Kafka stream1.2 secPassed
delete a topic when a Spark job is running14 secPassed
deserialization of initial offset written by future version0.37 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics15 secPassed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)0.62 secPassed
get offsets from case insensitive parameters3 msPassed
id override2 secPassed
id prefix2.5 secPassed
input row metrics1.4 secPassed
maxOffsetsPerTrigger7.4 secPassed
read Kafka transactional messages: read_committed17 secPassed
read Kafka transactional messages: read_uncommitted10 secPassed
reset should reset all fields2.4 secPassed
subscribe topic by pattern with topic recreation between batches4 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)3.4 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)3.4 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)3.4 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)4.4 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)2.1 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)2.4 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)3.3 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)3.6 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)2.9 secFixed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)3.4 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)4.6 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)4.9 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)2.1 secFixed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)2 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)3.1 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)3.3 secPassed
subscribing topic by pattern with topic deletions11 secPassed
unsupported kafka configs15 msPassed