risingwavelabs / risingwave

Best-in-class stream processing, analytics, and management. Perform continuous analytics, or build event-driven applications, real-time ETL pipelines, and feature stores in minutes. Unified streaming and batch. PostgreSQL compatible.
https://go.risingwave.com/slack
Apache License 2.0
7.08k stars 585 forks source link

Tracking: Watermark #6042

Open TennyZhuang opened 2 years ago

TennyZhuang commented 2 years ago

RFC PR: risingwavelabs/rfcs#2 Implementation design doc: https://github.com/risingwavelabs/rfcs/blob/46123694776083788a08b880ab1fa27eda542b76/rfcs/0016-watermark-operators-explained.md

TennyZhuang commented 2 years ago

After some discussions, we can also clean the state in DynamicFilter executors.

tabVersion commented 1 year ago

will we handle watermark events from the upstream in CDC scenes?

hengm3467 commented 1 year ago

@TennyZhuang Do you think we can prepare external docs about watermark?