Canope Nerda created FLINK-29692: ------------------------------------ Summary: Support early/late fires for Windowing TVFs Key: FLINK-29692 URL: https://issues.apache.org/jira/browse/FLINK-29692 Project: Flink Issue Type: Improvement Components: Table SQL / Planner Affects Versions: 1.15.2 Reporter: Canope Nerda
I have cases where I need to 1) output data as soon as possible and 2) handle late arriving data to achieve eventual correctness. In the logic, I need to do window deduplication which is based on Windowing TVFs and according to source code, early/late fires are not supported yet in Windowing TVFs. Actually 1) contradicts with 2). Without early/late fires, we had to compromise, either live with fresh incorrect data or tolerate excess latency for correctness. -- This message was sent by Atlassian Jira (v8.20.10#820010)