Test Result : KafkaMicroBatchV2SourceSuite

16 failures (+16)
52 tests (±0)
Took 31 min.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets18 secPassed
0 (SPARK-19517)1 min 14 secRegression
41 min 0 secRegression
Kafka column types8.2 secPassed
KafkaSource with watermark1 min 0 secRegression
Max should not overflow integer during end offset calculation11 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in45 secRegression
SPARK-27494: read kafka record containing null key/values1 min 0 secRegression
SPARK-30656: minPartitions1 min 0 secRegression
V2 Source is used by default1 min 0 secRegression
assign from earliest offsets (failOnDataLoss: false)13 secPassed
assign from earliest offsets (failOnDataLoss: true)11 secPassed
assign from latest offsets (failOnDataLoss: false)23 secPassed
assign from latest offsets (failOnDataLoss: true)24 secPassed
assign from specific offsets (failOnDataLoss: false)18 secPassed
assign from specific offsets (failOnDataLoss: true)8.2 secPassed
assign from specific timestamps (failOnDataLoss: false)12 secPassed
assign from specific timestamps (failOnDataLoss: true)21 secPassed
bad source options31 msPassed
cannot stop Kafka stream8.4 secPassed
delete a topic when a Spark job is running1 min 0 secRegression
deserialization of initial offset written by future version56 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics1 min 1 secRegression
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)12 secPassed
get offsets from case insensitive parameters0 msPassed
id override1 min 0 secRegression
id prefix1 min 0 secRegression
input row metrics48 secPassed
maxOffsetsPerTrigger2 min 3 secPassed
minPartitions is supported10 secRegression
read Kafka transactional messages: read_committed1 min 0 secRegression
read Kafka transactional messages: read_uncommitted1 min 24 secRegression
reset should reset all fields1 min 0 secRegression
subscribe topic by pattern with topic recreation between batches47 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)36 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)17 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)37 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)14 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)13 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)8.1 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: false)35 secPassed
subscribing topic by name from specific timestamps (failOnDataLoss: true)11 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)1 min 9 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)19 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)23 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)21 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)55 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)21 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: false)1 min 1 secPassed
subscribing topic by pattern from specific timestamps (failOnDataLoss: true)25 secPassed
subscribing topic by pattern with topic deletions1 min 20 secRegression
unsupported kafka configs28 msPassed