shanthoosh opened a new pull request #1401: URL: https://github.com/apache/samza/pull/1401
*Symptom:* Input messages consumed by the Samza SQL queries were incorrectly serialized. *Cause:* Samza SQL engine uses `AvroRelConverter` to convert the input messages from Avro-type to `SamzaSqlRelRecord` before they're processed by the high-level operators in samza. Currently `AvroRelConverter` incorrectly converts the nested non-nullable unions in the input messages. If the schema of input event contains nested non-nullable union, then `AvroRelConverter` always produces null values for corresponding fields in resultant `SamzaSQLRelRecord`. This problem happens since cached schema of input source is used to convert the input event to `SamzaSqlRelRecord`. *Changes:* Use the input event schema to convert the event to SamzaSqlRelRecord rather than using the cached-schema. *API changes:* None *Upgrade Instructions:* None *Usage Instructions:* None ---------------------------------------------------------------- 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]
