arnoldwakim opened a new pull request, #437:
URL: https://github.com/apache/arrow-go/pull/437

   ### Rationale for this change
   This PR fixes #435. 
   If writing to the RecordWriter fails, the current implementation does not 
drain the channel when 
   
   ### What changes are included in this PR?
   We add a deferred function that will drain the channel and call `.Release()` 
on the underlying `StreamChunks` in order to be able to release the 
RecordReader.
   
   ### Are these changes tested?
   @zeroshade as you suggested, I'll gladly accept a recommendation for the 
test setup. 
   
   ### Are there any user-facing changes?
   No.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscr...@arrow.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to