You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@gobblin.apache.org by "Hung Tran (JIRA)" <ji...@apache.org> on 2018/11/14 00:57:00 UTC
[jira] [Resolved] (GOBBLIN-629) Skip updating statistics for Kafka
partitions in KafkaExtractor when topic is skipped.
[ https://issues.apache.org/jira/browse/GOBBLIN-629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hung Tran resolved GOBBLIN-629.
-------------------------------
Resolution: Fixed
Issue resolved by pull request #2499
[https://github.com/apache/incubator-gobblin/pull/2499]
> 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
> Priority: Major
> 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)