[jira] [Resolved] (GOBBLIN-1355) Make task interruption optional on Gobblin task cancellation

["Hung Tran (Jira)" <ji...@apache.org>]

     [ 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)