[GOBBLIN-629] Skip updating statistics for Kafka partitions in KafkaExtractor when topic is skipped.

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.14.0
• Fix Version/s: 0.14.0
• Component/s: gobblin-kafka
• Assignee: Sudarshan Vasudevan
• Reporter: Sudarshan Vasudevan
• Created: 13/Nov/18 21:40
• Updated: 14/Nov/18 00:56
• Resolved: 14/Nov/18 00:56

Description

If the extractor skips processing of a Kafka topic due to an error condition (e.g. SchemaRegistryTimeoutException), then the close() method on KafkaExtractor throws an ArrayIndexOutOfBoundsException when attempting to update statistics for the partitions of the topic. The correct behavior should be to skip the call to updateStatisticsForCurrentPartition(), when a topic is skipped.