Jingsong Lee created FLINK-31311: ------------------------------------ Summary: Supports Bounded Watermark streaming read Key: FLINK-31311 URL: https://issues.apache.org/jira/browse/FLINK-31311 Project: Flink Issue Type: Improvement Components: Table Store Reporter: Jingsong Lee Assignee: Jingsong Lee Fix For: table-store-0.4.0
There are some bound stream scenarios that require that stream reading can be ended. Generally speaking, the end event time is the better. So in this ticket, supports writing the watermark to the snapshot and can specify the ending watermark when reading the stream. -- This message was sent by Atlassian Jira (v8.20.10#820010)