lakshmi-manasa-g opened a new pull request #1392: URL: https://github.com/apache/samza/pull/1392
**Bug fix** **Symptom:** NPE thrown during SystemProducer.flush if AzureBlobAvroWriter earlier threw an IllegalStateException. **Cause:** First message passed into AzureBlobAvroWriter is a bad record without schema then the avro objects are not created due to IllegalStateException. However, if the user of the system producer still invokes a flush (either directly or through stop), NPE is thrown as flush of producer invokes flush of the writer which inturn accesses the non-existent avro objects. **Changes:** check if the avro components are not null before accessing. API changes: None Upgrade Instructions: None Usage Instructions: None Tests: existing tests pass ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
