Test Result : KafkaMicroBatchV1SourceSuite

0 failures (±0)
41 tests (±0)
Took 3 min 27 sec.

All Tests

Test nameDurationStatus
(de)serialization of initial offsets0.76 secPassed
Kafka column types1.4 secPassed
KafkaSource with watermark2.4 secPassed
SPARK-22956: currentPartitionOffsets should be set when no new data comes in4.5 secPassed
SPARK-25495: FetchedData.reset should reset all fields2.7 secPassed
SPARK-26718 Rate limit set to Long.Max should not overflow integer during end offset calculation2 secPassed
SPARK-27494: read kafka record containing null key/values.1.4 secPassed
V1 Source is used when disabled through SQLConf0.73 secPassed
assign from earliest offsets (failOnDataLoss: false)7.2 secPassed
assign from earliest offsets (failOnDataLoss: true)7.2 secPassed
assign from latest offsets (failOnDataLoss: false)8.4 secPassed
assign from latest offsets (failOnDataLoss: true)8 secPassed
assign from specific offsets (failOnDataLoss: false)4.3 secPassed
assign from specific offsets (failOnDataLoss: true)4.2 secPassed
bad source options17 msPassed
cannot stop Kafka stream1 secPassed
delete a topic when a Spark job is running4.4 secPassed
deserialization of initial offset written by Spark 2.1.0 (SPARK-19517)3.4 secPassed
deserialization of initial offset written by future version0.27 secPassed
ensure stream-stream self-join generates only one offset in log and correct metrics14 secPassed
ensure that initial offset are written with an extra byte in the beginning (SPARK-19517)0.78 secPassed
get offsets from case insensitive parameters1 msPassed
input row metrics2.4 secPassed
maxOffsetsPerTrigger4.3 secPassed
read Kafka transactional messages: read_committed16 secPassed
read Kafka transactional messages: read_uncommitted11 secPassed
subscribe topic by pattern with topic recreation between batches3.6 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: false)7.3 secPassed
subscribing topic by name from earliest offsets (failOnDataLoss: true)8.2 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: false)9.1 secPassed
subscribing topic by name from latest offsets (failOnDataLoss: true)9.1 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: false)4.3 secPassed
subscribing topic by name from specific offsets (failOnDataLoss: true)4.1 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: false)7.3 secPassed
subscribing topic by pattern from earliest offsets (failOnDataLoss: true)8.3 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: false)7.8 secPassed
subscribing topic by pattern from latest offsets (failOnDataLoss: true)9 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: false)4.2 secPassed
subscribing topic by pattern from specific offsets (failOnDataLoss: true)4.2 secPassed
subscribing topic by pattern with topic deletions5.1 secPassed
unsupported kafka configs19 msPassed