with minPartition = 1: SPARK-30656: minPartitions less than the length of topic partitions | 1 ms | Passed |
with minPartition = 3: N TopicPartitions to N offset ranges | 4 ms | Passed |
with minPartition = 3: N skewed TopicPartitions to M offset ranges | 0 ms | Passed |
with minPartition = 3: SPARK-30656: N very skewed TopicPartitions to M offset ranges | 1 ms | Passed |
with minPartition = 3: empty ranges ignored | 1 ms | Passed |
with minPartition = 3: range inexact multiple of minPartitions | 0 ms | Passed |
with minPartition = 4: 1 TopicPartition to N offset ranges | 1 ms | Passed |
with minPartition = 4: SPARK-30656: ignore empty ranges and split the rest | 1 ms | Passed |
with minPartition = 6: SPARK-28489: never drop offsets | 0 ms | Passed |
with no minPartition: N TopicPartitions to N offset ranges | 13 ms | Passed |
with no minPartition: empty ranges ignored | 1 ms | Passed |