Hi, The Window#withAllowedLateness(Duration) doc says "Any elements that are later than this as decided by the system-maintained watermark will be dropped". Can the runner safely discard a tuple that violates the allowed lateness in the Window operator? Or does it have to drop it in the downstream GBK operator just in case that there could be another Window transform in between overriding the allowed lateness (or other configurations)?
Thanks, Shen
