Test Result : KafkaMicroBatchV2SourceSuite

5 failures (+5)
52 tests (±0)
Took 19 min.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets1.8 secPassed
0 (SPARK-19517)6.8 secPassed
413 secRegression
Kafka column types4.9 secPassed
KafkaSource with watermark13 secPassed
Max should not overflow integer during end offset calculation4 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in57 secPassed
SPARK-27494: read kafka record containing null key/values1 min 41 secPassed
SPARK-30656: minPartitions29 secPassed
V2 Source is used by default11 secPassed
assign from earliest offsets (failOnDataLoss: false)9.2 secPassed
assign from earliest offsets (failOnDataLoss: true)7.9 secPassed
assign from latest offsets (failOnDataLoss: false)11 secPassed
assign from latest offsets (failOnDataLoss: true)14 secPassed
assign from specific offsets (failOnDataLoss: false)13 secPassed
assign from specific offsets (failOnDataLoss: true)4.6 secPassed
assign from specific timestamps (failOnDataLoss: false)11 secPassed
assign from specific timestamps (failOnDataLoss: true)7.4 secPassed
bad source options18 msPassed
cannot stop Kafka stream12 secPassed
delete a topic when a Spark job is running24 secPassed
deserialization of initial offset written by future version4.2 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)43 secPassed
get offsets from case insensitive parameters0 msPassed
id override7 secPassed
id prefix17 secPassed
input row metrics6.4 secPassed
maxOffsetsPerTrigger41 secPassed
minPartitions is supported5.8 secPassed
read Kafka transactional messages: read_committed1 min 49 secPassed
read Kafka transactional messages: read_uncommitted1 min 0 secRegression
reset should reset all fields1 min 0 secRegression
subscribe topic by pattern with topic recreation between batches1 min 0 secRegression
subscribing topic by name from earliest offsets (failOnDataLoss: false)17 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)10 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)18 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)17 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)10 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)8.2 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)18 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)14 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)18 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)21 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)17 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)10 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)10 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)7.5 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)19 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)27 secPassed
subscribing topic by pattern with topic deletions1 min 24 secRegression
unsupported kafka configs35 msPassed