SPARK-19886: Report error cause correctly in reportDataLoss | 0.71 sec | Passed |
SPARK-23623: concurrent use of KafkaDataConsumer | 5 min 28 sec | Passed |
SPARK-25151 Handles multiple tasks in executor fetching same (topic, partition) pair | 59 sec | Regression |
SPARK-25151 Handles multiple tasks in executor fetching same (topic, partition) pair and same offset (edge-case) - data in use | 4 min 0 sec | Regression |
SPARK-25151 Handles multiple tasks in executor fetching same (topic, partition) pair and same offset (edge-case) - data not in use | 5 min 18 sec | Passed |
new KafkaDataConsumer instance in case of Task retry | 43 ms | Passed |
new KafkaDataConsumer instance in case of token renewal | 36 ms | Passed |
same KafkaDataConsumer instance in case of same token | 1.3 sec | Passed |