Hung Tran created GOBBLIN-774:
---------------------------------

             Summary: Send nack when a control message handler fails in Fork
                 Key: GOBBLIN-774
                 URL: https://issues.apache.org/jira/browse/GOBBLIN-774
             Project: Apache Gobblin
          Issue Type: Task
            Reporter: Hung Tran
            Assignee: Hung Tran


Fork will raise an error without ack/nacking if the control message handler 
raises an error. This can result in another thread waiting indefinitely for a 
control message ack. Fork.

consumeRecordStream() should handle control message exceptions by calling 
nack() with the exception before reraising the error.



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

Reply via email to