[SAMZA-2029] Samza-SQL Diagnostics: propagate eventTime and assign arrivalTime

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Done
• Component/s: sql
• Assignee: Unassigned
• Reporter: Shenoda Guirguis
• Created: 05/Dec/18 23:25
• Updated: 31/Jan/19 02:01
• Resolved: 31/Jan/19 02:01

Description

a) upon receiving a new event message, check if eventTime is available, and if so copy it to message metadata, to propagate to SamzaSQL layer.

b) upon converting the event message to SamzaSQLRelMessage, assign current-time to be the event's arrival time (in the message metadata)

Issue Links

• links to: GitHub Pull Request #863