Test Result : KafkaMicroBatchV1SourceSuite

2 failures (+2)
50 tests (±0)
Took 16 min.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets2.6 secPassed
0 (SPARK-19517)6.2 secPassed
Kafka column types3.2 secPassed
KafkaSource with watermark10 secPassed
Max should not overflow integer during end offset calculation14 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in41 secPassed
SPARK-27494: read kafka record containing null key/values3.3 secPassed
SPARK-30656: minPartitions6.3 secPassed
V1 Source is used when disabled through SQLConf3.7 secPassed
assign from earliest offsets (failOnDataLoss: false)10 secPassed
assign from earliest offsets (failOnDataLoss: true)16 secPassed
assign from latest offsets (failOnDataLoss: false)10 secPassed
assign from latest offsets (failOnDataLoss: true)13 secPassed
assign from specific offsets (failOnDataLoss: false)14 secPassed
assign from specific offsets (failOnDataLoss: true)8.3 secPassed
assign from specific timestamps (failOnDataLoss: false)12 secPassed
assign from specific timestamps (failOnDataLoss: true)12 secPassed
bad source options28 msPassed
cannot stop Kafka stream5 secPassed
delete a topic when a Spark job is running23 secPassed
deserialization of initial offset written by future version1.4 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics54 secPassed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)1.9 secPassed
get offsets from case insensitive parameters1 msPassed
id override12 secPassed
id prefix7.5 secPassed
input row metrics5.9 secPassed
maxOffsetsPerTrigger53 secPassed
read Kafka transactional messages: read_committed39 secPassed
read Kafka transactional messages: read_uncommitted39 secPassed
reset should reset all fields5.4 secPassed
subscribe topic by pattern with topic recreation between batches14 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)14 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)13 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)18 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)16 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)9.6 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)8.7 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)20 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)23 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)1 min 26 secRegression
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)16 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)32 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)17 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)1 min 39 secRegression
subscribing topic by pattern from specific offsets (failOnDataLoss: true)10 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)1 min 25 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)20 secPassed
subscribing topic by pattern with topic deletions19 secPassed
unsupported kafka configs36 msPassed