[
https://issues.apache.org/jira/browse/GOBBLIN-1355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hung Tran resolved GOBBLIN-1355.
--------------------------------
Resolution: Fixed
Issue resolved by pull request #3195
[https://github.com/apache/incubator-gobblin/pull/3195]
> Make task interruption optional on Gobblin task cancellation
> ------------------------------------------------------------
>
> Key: GOBBLIN-1355
> URL: https://issues.apache.org/jira/browse/GOBBLIN-1355
> Project: Apache Gobblin
> Issue Type: Improvement
> Components: gobblin-core
> Affects Versions: 0.16.0
> Reporter: Sudarshan Vasudevan
> Assignee: Abhishek Tiwari
> Priority: Major
> Fix For: 0.16.0
>
> Time Spent: 1h 20m
> Remaining Estimate: 0h
>
> Currently, the thread running a Gobblin task is interrupted when a task
> cancellation is invoked. When such a task is managing a Kafka consumer for
> instance, the interrupt leaves the consumer instance in a corrupt state,
> particularly if the consumer is in the middle of a poll() when the interrupt
> occurs. This in turn prevents the subsequent clean up of the consumer
> instance resulting in a potential resource leak.
> With this change, we provide the option to avoid interrupting the thread in
> aforementioned scenarios and let the poll() return before the thread is
> shutdown.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
