MultipleOutputs#close() should pass appropriate context rather than using same context
Description
Release Notes
None
relates to
Activity
Show:
Ali Anwar November 2, 2016 at 9:39 PM
Cherry-pick to release/3.5: https://github.com/caskdata/cdap/pull/7052
Vinisha Shah October 28, 2016 at 9:47 PM
Fixed
Pinned fields
Click on the next to a field label to start pinning.
Created October 28, 2016 at 9:42 PM
Updated November 3, 2016 at 9:06 PM
Resolved November 3, 2016 at 9:06 PM
MultipleOutputs#close() should pass appropriate task context rather than using same context. Current implementation uses same taskAttemptContext which is passed in RecordWriter#close() method. So if any config field is added in RecordWriter#write() method it will not be accessible from RecordWriter#close()