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

24 failures (+24)
237 tests (-5)
Took 1 hr 41 min.

All Failed Tests

Test NameDurationAge
 org.apache.spark.sql.kafka010.KafkaContinuousSinkSuite.generic - write big data with small producer buffer7 min 59 sec1
 org.apache.spark.sql.kafka010.KafkaContinuousSinkSuite.streaming - write w/o topic field, with topic option1 min 8 sec1
 org.apache.spark.sql.kafka010.KafkaDontFailOnDataLossSuite.failOnDataLoss=false should not return duplicated records: batch v11 min 55 sec1
 org.apache.spark.sql.kafka010.KafkaDontFailOnDataLossSuite.failOnDataLoss=false should not return duplicated records: batch v245 sec1
 org.apache.spark.sql.kafka010.KafkaDontFailOnDataLossSuite.failOnDataLoss=false should not return duplicated records: continuous processing55 sec1
 org.apache.spark.sql.kafka010.KafkaDontFailOnDataLossSuite.failOnDataLoss=false should not return duplicated records: microbatch v143 sec1
 org.apache.spark.sql.kafka010.KafkaDontFailOnDataLossSuite.failOnDataLoss=false should not return duplicated records: microbatch v234 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.subscribing topic by pattern from earliest offsets (failOnDataLoss: false)1 min 26 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV1SourceSuite.subscribing topic by pattern from specific offsets (failOnDataLoss: false)1 min 39 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.413 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.read Kafka transactional messages: read_uncommitted1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.reset should reset all fields1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.subscribe topic by pattern with topic recreation between batches1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaMicroBatchV2SourceSuite.subscribing topic by pattern with topic deletions1 min 24 sec1
 org.apache.spark.sql.kafka010.KafkaOffsetReaderSuite.SPARK-30656: getOffsetRangesFromResolvedOffsets1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaOffsetReaderSuite.SPARK-30656: getOffsetRangesFromUnresolvedOffsets - multiple topic partitions1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaOffsetReaderSuite.SPARK-30656: getOffsetRangesFromUnresolvedOffsets - using special offsets1 min 0 sec1
 org.apache.spark.sql.kafka010.KafkaOffsetReaderSuite.SPARK-30656: getOffsetRangesFromUnresolvedOffsets - using specific offsets28 sec1
 org.apache.spark.sql.kafka010.KafkaSinkBatchSuiteV1.SPARK-20496: batch - enforce analyzed plans2 min 38 sec1
 org.apache.spark.sql.kafka010.KafkaSinkBatchSuiteV1.batch - partition column and partitioner priorities1 min 4 sec1
 org.apache.spark.sql.kafka010.KafkaSinkBatchSuiteV1.batch - unsupported save modes1 min 4 sec1
 org.apache.spark.sql.kafka010.KafkaSinkBatchSuiteV1.batch - write to kafka1 min 5 sec1
 org.apache.spark.sql.kafka010.KafkaSinkBatchSuiteV2.(It is not a test it is a sbt.testing.SuiteSelector)54 sec1
 org.apache.spark.sql.kafka010.KafkaSourceStressForDontFailOnDataLossSuite.stress test for failOnDataLoss=false1 min 6 sec1

All Tests

ClassDurationFail(diff)Skip(diff)Pass(diff)Total(diff)
JsonUtilsSuite0.2 sec0022
KafkaContinuousSinkSuite10 min2+206-28
KafkaContinuousSourceStressForDontFailOnDataLossSuite23 sec0011
KafkaContinuousSourceSuite8 min 21 sec003333
KafkaContinuousSourceTopicDeletionSuite25 sec0022
KafkaDelegationTokenSuite18 sec0011
KafkaDontFailOnDataLossSuite4 min 54 sec5+500-55
KafkaMicroBatchV1SourceSuite16 min2+2048-250
KafkaMicroBatchV2SourceSuite19 min5+5047-552
KafkaOffsetRangeCalculatorSuite0.29 sec001111
KafkaOffsetReaderSuite3 min 28 sec4+400-44
KafkaRelationSuiteV18 min 20 sec002020
KafkaRelationSuiteV210 min002020
KafkaSinkBatchSuiteV15 min 54 sec4+401-45
KafkaSinkBatchSuiteV254 sec1+100-61-5
KafkaSinkMicroBatchStreamingSuite2 min 44 sec0088
KafkaSourceOffsetSuite0.33 sec0088
KafkaSourceProviderSuite0.57 sec0033
KafkaSourceStressForDontFailOnDataLossSuite1 min 6 sec1+100-11
KafkaSourceStressSuite8 min 40 sec0011
KafkaSparkConfSuite2 ms0011