Jingsong Lee created FLINK-19722: ------------------------------------ Summary: Pushdown Watermark to SourceProvider (new Source) Key: FLINK-19722 URL: https://issues.apache.org/jira/browse/FLINK-19722 Project: Flink Issue Type: Sub-task Components: Table SQL / Planner Reporter: Jingsong Lee
See {{StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy)}} The new source can get watermark strategy to handle split watermark. -- This message was sent by Atlassian Jira (v8.3.4#803005)