Hi all, I’d like to initiate a discussion about introducing early fire support for Flink SQL interval joins.
*Motivation* In many streaming applications, particularly real-time analytics and monitoring systems, it is valuable to obtain partial results earlier rather than waiting for full join conditions to finalize. For Flink SQL interval joins, results are typically delayed until watermarks ensure no more matches can occur. This delay can be challenging for scenarios that require fast feedback. Early fire support addresses this by emitting intermediate results speculatively and using retractions or updates to maintain eventual consistency and ensure correctness. Here’s the proposal document: Link <https://docs.google.com/document/d/1YobpNdnvzSsceniVj4NZWi445gb1-54Rox-D7nPArZo/edit?tab=t.0#heading=h.z7bl0h2hwkph> Your feedback and ideas are welcome to refine this feature. Thanks, Weiqing
