Kenneth Knowles created BEAM-6110:
-------------------------------------
Summary: Beam SQL join moves element timestamps to EOW sometimes,
not always
Key: BEAM-6110
URL: https://issues.apache.org/jira/browse/BEAM-6110
Project: Beam
Issue Type: Bug
Components: dsl-sql
Reporter: Kenneth Knowles
Assignee: Kenneth Knowles
When a CoGBK join is chosen, element timestamps move to EOW. When side input or
lookup join is chosen, element timestamps are the timestamps from the main
input element. In SQL sementics, these timestamps are not observable, as
windowing is assigned at the next GROUP BY. So we just need the output to hold
the watermark so that nothing becomes late or droppable, which implies we need
to use MIN timestamp combiner.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
