Test Result : KafkaMicroBatchV1SourceSuite

0 failures (-5)
50 tests (±0)
Took 9 min 42 sec.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets2.8 secPassed
0 (SPARK-19517)2.8 secPassed
Kafka column types4.5 secPassed
KafkaSource with watermark5.4 secPassed
Max should not overflow integer during end offset calculation4.4 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in17 secPassed
SPARK-27494: read kafka record containing null key/values3.5 secPassed
SPARK-30656: minPartitions4.1 secPassed
V1 Source is used when disabled through SQLConf1.5 secPassed
assign from earliest offsets (failOnDataLoss: false)8.7 secFixed
assign from earliest offsets (failOnDataLoss: true)8.9 secPassed
assign from latest offsets (failOnDataLoss: false)9.4 secPassed
assign from latest offsets (failOnDataLoss: true)19 secPassed
assign from specific offsets (failOnDataLoss: false)11 secPassed
assign from specific offsets (failOnDataLoss: true)10 secPassed
assign from specific timestamps (failOnDataLoss: false)11 secPassed
assign from specific timestamps (failOnDataLoss: true)14 secPassed
bad source options18 msPassed
cannot stop Kafka stream14 secPassed
delete a topic when a Spark job is running15 secFixed
deserialization of initial offset written by future version0.61 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)1.5 secPassed
get offsets from case insensitive parameters2 msPassed
id override5.6 secPassed
id prefix8.6 secPassed
input row metrics4.8 secPassed
maxOffsetsPerTrigger37 secPassed
read Kafka transactional messages: read_committed35 secFixed
read Kafka transactional messages: read_uncommitted18 secFixed
reset should reset all fields6.7 secPassed
subscribe topic by pattern with topic recreation between batches7.2 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)15 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)24 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)13 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)18 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)6.5 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)10 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)13 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)12 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)6.1 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)9.4 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)15 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)14 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)4.9 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)11 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)9.9 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)16 secFixed
subscribing topic by pattern with topic deletions38 secPassed
unsupported kafka configs14 msPassed