Test Result : org.apache.spark.sql.kafka010

55 failures (+55)
242 tests (±0)
Took 2 hr 10 min.

All Failed Tests

Test NameDurationAge
 org.apache.spark.sql.kafka010.KafkaContinuousSourceStressForDontFailOnDataLossSuite.stress test for failOnDataLoss=false57 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.Kafka column types1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.SPARK-27494: read kafka record containing null key/values1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from earliest offsets (failOnDataLoss: false)1 min 1 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from earliest offsets (failOnDataLoss: true)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from latest offsets (failOnDataLoss: false)1 min 9 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from latest offsets (failOnDataLoss: true)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from specific offsets (failOnDataLoss: false)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from specific offsets (failOnDataLoss: true)1 min 4 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from specific timestamps (failOnDataLoss: false)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from specific timestamps (failOnDataLoss: true)1 min 3 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.cannot stop Kafka stream1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.read Kafka transactional messages: read_committed1 min 1 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.read Kafka transactional messages: read_uncommitted1 min 44 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from earliest offsets (failOnDataLoss: false)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from earliest offsets (failOnDataLoss: true)1 min 11 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from latest offsets (failOnDataLoss: false)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from latest offsets (failOnDataLoss: true)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from specific offsets (failOnDataLoss: false)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from specific offsets (failOnDataLoss: true)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from specific timestamps (failOnDataLoss: false)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from specific timestamps (failOnDataLoss: true)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from earliest offsets (failOnDataLoss: false)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from earliest offsets (failOnDataLoss: true)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from latest offsets (failOnDataLoss: false)1 min 1 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from latest offsets (failOnDataLoss: true)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from specific offsets (failOnDataLoss: false)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from specific offsets (failOnDataLoss: true)1 min 2 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from specific timestamps (failOnDataLoss: false)1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from specific timestamps (failOnDataLoss: true)1 min 2 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSourceTopicDeletionSuite.subscribing topic by pattern with topic deletions2 min 46 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.assign from earliest offsets (failOnDataLoss: false)40 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.delete a topic when a Spark job is running14 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.read Kafka transactional messages: read_committed1 min 1 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.read Kafka transactional messages: read_uncommitted1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.subscribing topic by pattern from specific timestamps (failOnDataLoss: true)57 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.0 (SPARK-19517)1 min 14 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.41 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.KafkaSource with watermark1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.SPARK-22956: currentPartitionOffsets should be set when no new data comes in45 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.SPARK-27494: read kafka record containing null key/values1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.SPARK-30656: minPartitions1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.V2 Source is used by default1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.delete a topic when a Spark job is running1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.ensure stream-stream self-join generates only one offset in log and correct metrics1 min 1 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.id override1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.id prefix1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.minPartitions is supported10 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.read Kafka transactional messages: read_committed1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.read Kafka transactional messages: read_uncommitted1 min 24 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.reset should reset all fields1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.subscribing topic by pattern with topic deletions1 min 20 sec1
 org.apache.spark.sql.kafka010.KafkaRelationSuiteV2.reuse same dataframe in query16 sec1
 org.apache.spark.sql.kafka010.KafkaRelationSuiteV2.test late binding start offsets44 sec1
 org.apache.spark.sql.kafka010.KafkaSourceStressSuite.stress test with multiple topics and partitions5 min 49 sec1

All Tests

ClassDurationFail(diff)Skip(diff)Pass(diff)Total(diff)
JsonUtilsSuite30 ms0022
KafkaContinuousSinkSuite8 min 16 sec0088
KafkaContinuousSourceStressForDontFailOnDataLossSuite57 sec1+100-11
KafkaContinuousSourceSuite30 min29+2904-2933
KafkaContinuousSourceTopicDeletionSuite2 min 46 sec1+101-12
KafkaDelegationTokenSuite23 sec0011
KafkaDontFailOnDataLossSuite2 min 43 sec0055
KafkaMicroBatchV1SourceSuite23 min5+5045-550
KafkaMicroBatchV2SourceSuite31 min16+16036-1652
KafkaOffsetRangeCalculatorSuite0.15 sec001111
KafkaOffsetReaderSuite53 sec0044
KafkaRelationSuiteV13 min 52 sec002020
KafkaRelationSuiteV26 min 32 sec2+2018-220
KafkaSinkBatchSuiteV123 sec0055
KafkaSinkBatchSuiteV210 min0066
KafkaSinkMicroBatchStreamingSuite1 min 25 sec0088
KafkaSourceOffsetSuite1.7 sec0088
KafkaSourceProviderSuite1.7 sec0033
KafkaSourceStressForDontFailOnDataLossSuite20 sec0011
KafkaSourceStressSuite5 min 49 sec1+100-11
KafkaSparkConfSuite0.37 sec0011