[
https://issues.apache.org/jira/browse/FLINK-14326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu resolved FLINK-14326.
-----------------------------
Fix Version/s: 1.10.0
Resolution: Fixed
[hotfix][table-planner-blink] Move SqlToOperationConverterTest from sqlexec
package to operations package
- 1.10.0: 937356f786b5edac28a7ff44fc31410761c6d7f0
[FLINK-14326][table-planner-blink] Support to generate and apply watermark
assigner in translateToPlan
- 1.10.0: d0901dc70205d171fe0a777f99e800929e2231a6
[FLINK-14326][table-planner-blink] Support code generate a WatermarkGenerator
from RexNode
- 1.10.0: bf27bdd1ffe4f28b14f4ee14cc0863e8dc70422b
[FLINK-14326][table-planner-blink] Introduce WatermarkGenerator interface to
generate watermark from current row
- 1.10.0: d98ad19e030fb4b6c3e26fd2b96726e2be77ef5c
[hotfix][table-planner-blink] Make sure TableSourceTable.catalogTable is not
null
- 1.10.0: 5acf09d62edb6070846d1d537f728ca89d9c3cc8
> Support to apply watermark assigner according to the WatermarkSpec in
> TableSourceTable
> --------------------------------------------------------------------------------------
>
> Key: FLINK-14326
> URL: https://issues.apache.org/jira/browse/FLINK-14326
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Runtime
> Reporter: Jark Wu
> Assignee: Jark Wu
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.10.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> Apply watermark assigner according to the {{WatermarkSpec}} in
> {{TableSourceTable}} when {{StreamExecTableSourceScan#translateToPlan}}.
> Ignore TableSource’s {{DefinedRowtimeAttributes}} if {{WatermarkSpec}}
> exists.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
