[jira] [Resolved] (CARBONDATA-2417) SDK writer goes to infinite wait when consumer thread goes dead

[Akash R Nilugal (Jira)]

     [ https://issues.apache.org/jira/browse/CARBONDATA-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ravindra Pesala resolved CARBONDATA-2417.
-----------------------------------------
       Resolution: Fixed
    Fix Version/s: 1.4.0

> SDK writer goes to infinite wait when consumer thread goes dead
> ---------------------------------------------------------------
>
>                 Key: CARBONDATA-2417
>                 URL: https://issues.apache.org/jira/browse/CARBONDATA-2417
>             Project: CarbonData
>          Issue Type: Bug
>            Reporter: Ajantha Bhat
>            Assignee: Ajantha Bhat
>            Priority: Major
>             Fix For: 1.4.0
>
>          Time Spent: 2.5h
>  Remaining Estimate: 0h
>
> problem: SDK writer goes to infinite wait when cosumer thread is dead
> root cause: due to bad record when exception happens at consumer thread during write, this message  is not reached producer (sdk writer).
> So, SDK keeps writing data assuming consumer will consume it. But as consumer is dead. Queue becomes full and queue.put() will be blocked forever.
> Solution: If cannot be added to queue, check whether consumer is alive or not after every 10 seconds.
> If not alive throw exception, if alive try again

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