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

55 failures (+55)

242 tests (±0)

Took 2 hr 10 min.

All Failed Tests

Test Name	Duration	Age
org.apache.spark.sql.kafka010.KafkaContinuousSourceStressForDontFailOnDataLossSuite.stress test for failOnDataLoss=false Loading...	57 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.Kafka column types Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.SPARK-27494: read kafka record containing null key/values Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from earliest offsets (failOnDataLoss: false) Loading...	1 min 1 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from earliest offsets (failOnDataLoss: true) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from latest offsets (failOnDataLoss: false) Loading...	1 min 9 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from latest offsets (failOnDataLoss: true) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from specific offsets (failOnDataLoss: false) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from specific offsets (failOnDataLoss: true) Loading...	1 min 4 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from specific timestamps (failOnDataLoss: false) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.assign from specific timestamps (failOnDataLoss: true) Loading...	1 min 3 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.cannot stop Kafka stream Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.read Kafka transactional messages: read_committed Loading...	1 min 1 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.read Kafka transactional messages: read_uncommitted Loading...	1 min 44 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from earliest offsets (failOnDataLoss: false) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from earliest offsets (failOnDataLoss: true) Loading...	1 min 11 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from latest offsets (failOnDataLoss: false) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from latest offsets (failOnDataLoss: true) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from specific offsets (failOnDataLoss: false) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from specific offsets (failOnDataLoss: true) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from specific timestamps (failOnDataLoss: false) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by name from specific timestamps (failOnDataLoss: true) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from earliest offsets (failOnDataLoss: false) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from earliest offsets (failOnDataLoss: true) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from latest offsets (failOnDataLoss: false) Loading...	1 min 1 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from latest offsets (failOnDataLoss: true) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from specific offsets (failOnDataLoss: false) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from specific offsets (failOnDataLoss: true) Loading...	1 min 2 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from specific timestamps (failOnDataLoss: false) Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceSuite.subscribing topic by pattern from specific timestamps (failOnDataLoss: true) Loading...	1 min 2 sec	1
org.apache.spark.sql.kafka010.KafkaContinuousSourceTopicDeletionSuite.subscribing topic by pattern with topic deletions Loading...	2 min 46 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.assign from earliest offsets (failOnDataLoss: false) Loading...	40 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.delete a topic when a Spark job is running Loading...	14 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.read Kafka transactional messages: read_committed Loading...	1 min 1 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.read Kafka transactional messages: read_uncommitted Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.subscribing topic by pattern from specific timestamps (failOnDataLoss: true) Loading...	57 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.0 (SPARK-19517) Loading...	1 min 14 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.4 Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.KafkaSource with watermark Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.SPARK-22956: currentPartitionOffsets should be set when no new data comes in Loading...	45 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.SPARK-27494: read kafka record containing null key/values Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.SPARK-30656: minPartitions Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.V2 Source is used by default Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.delete a topic when a Spark job is running Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.ensure stream-stream self-join generates only one offset in log and correct metrics Loading...	1 min 1 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.id override Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.id prefix Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.minPartitions is supported Loading...	10 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.read Kafka transactional messages: read_committed Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.read Kafka transactional messages: read_uncommitted Loading...	1 min 24 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.reset should reset all fields Loading...	1 min 0 sec	1
org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.subscribing topic by pattern with topic deletions Loading...	1 min 20 sec	1
org.apache.spark.sql.kafka010.KafkaRelationSuiteV2.reuse same dataframe in query Loading...	16 sec	1
org.apache.spark.sql.kafka010.KafkaRelationSuiteV2.test late binding start offsets Loading...	44 sec	1
org.apache.spark.sql.kafka010.KafkaSourceStressSuite.stress test with multiple topics and partitions Loading...	5 min 49 sec	1

All Tests

Class	Duration	Fail	(diff)	Skip	(diff)	Pass	(diff)	Total	(diff)
JsonUtilsSuite	30 ms	0		0		2		2
KafkaContinuousSinkSuite	8 min 16 sec	0		0		8		8
KafkaContinuousSourceStressForDontFailOnDataLossSuite	57 sec	1	+1	0		0	-1	1
KafkaContinuousSourceSuite	30 min	29	+29	0		4	-29	33
KafkaContinuousSourceTopicDeletionSuite	2 min 46 sec	1	+1	0		1	-1	2
KafkaDelegationTokenSuite	23 sec	0		0		1		1
KafkaDontFailOnDataLossSuite	2 min 43 sec	0		0		5		5
KafkaMicroBatchV1SourceSuite	23 min	5	+5	0		45	-5	50
KafkaMicroBatchV2SourceSuite	31 min	16	+16	0		36	-16	52
KafkaOffsetRangeCalculatorSuite	0.15 sec	0		0		11		11
KafkaOffsetReaderSuite	53 sec	0		0		4		4
KafkaRelationSuiteV1	3 min 52 sec	0		0		20		20
KafkaRelationSuiteV2	6 min 32 sec	2	+2	0		18	-2	20
KafkaSinkBatchSuiteV1	23 sec	0		0		5		5
KafkaSinkBatchSuiteV2	10 min	0		0		6		6
KafkaSinkMicroBatchStreamingSuite	1 min 25 sec	0		0		8		8
KafkaSourceOffsetSuite	1.7 sec	0		0		8		8
KafkaSourceProviderSuite	1.7 sec	0		0		3		3
KafkaSourceStressForDontFailOnDataLossSuite	20 sec	0		0		1		1
KafkaSourceStressSuite	5 min 49 sec	1	+1	0		0	-1	1
KafkaSparkConfSuite	0.37 sec	0		0		1		1