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