[
https://issues.apache.org/jira/browse/SAMZA-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shenoda Guirguis updated SAMZA-2029:
------------------------------------
Summary: Samza-SQL Diagnostics: propagate eventTime and assign arrivalTime
(was: Samza-sql diagnostics: propagate eventTime and assign arrivalTime)
> Samza-SQL Diagnostics: propagate eventTime and assign arrivalTime
> -----------------------------------------------------------------
>
> Key: SAMZA-2029
> URL: https://issues.apache.org/jira/browse/SAMZA-2029
> Project: Samza
> Issue Type: Sub-task
> Components: sql
> Reporter: Shenoda Guirguis
> Priority: Major
>
> 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)
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)