You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@carbondata.apache.org by "Ajantha Bhat (JIRA)" <ji...@apache.org> on 2018/04/30 06:01:00 UTC

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

Ajantha Bhat created CARBONDATA-2417:
----------------------------------------

             Summary: 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


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)