You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "HunterHunter (Jira)" <ji...@apache.org> on 2022/06/10 09:39:00 UTC

[jira] [Updated] (FLINK-27993) When only use 'Flink SQL' to develop programs, `watermark` can be defined when creating view tables

     [ https://issues.apache.org/jira/browse/FLINK-27993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

HunterHunter updated FLINK-27993:
---------------------------------
    Summary: When only use 'Flink SQL' to develop programs, `watermark` can be defined when creating view tables  (was: When only use 'flex SQL' to develop programs, `watermark` can be defined when creating view tables)

> When only use 'Flink SQL' to develop programs, `watermark` can be defined when creating view tables
> ---------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-27993
>                 URL: https://issues.apache.org/jira/browse/FLINK-27993
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: HunterHunter
>            Priority: Major
>
> When I only use 'flex SQL' to develop programs, I cannot define watermarks from view table，I have a data source table a, which has only one field `messge`. I need to parse it into others fields(like `time` field), and then build a view table, but I have no place to define watermark.
> Or in other scenarios, I need to perform various transformations from a table to get the `eventtime` field. Or merge and convert from multiple tables to the final table
>  
> eg:
> create table A(
> messge string
> ) with( kafka )
> create view table B select udf(messge) as `eventtime`  from A.
> I can define `watermark` , as i know, I can only define it when creating a table.
>  
> My current practice is to mix Table APIs.
>  



--
This message was sent by Atlassian Jira
(v8.20.7#820007)