You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@gobblin.apache.org by "Sudarshan Vasudevan (JIRA)" <ji...@apache.org> on 2018/11/13 21:41:00 UTC

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

Sudarshan Vasudevan created GOBBLIN-629:
-------------------------------------------

             Summary: Skip updating statistics for Kafka partitions in KafkaExtractor when topic is skipped.  
                 Key: GOBBLIN-629
                 URL: https://issues.apache.org/jira/browse/GOBBLIN-629
             Project: Apache Gobblin
          Issue Type: Bug
          Components: gobblin-kafka
    Affects Versions: 0.14.0
            Reporter: Sudarshan Vasudevan
            Assignee: Sudarshan Vasudevan
             Fix For: 0.14.0


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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)