[ 
https://issues.apache.org/jira/browse/FLINK-16449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060281#comment-17060281
 ] 

Timo Walther commented on FLINK-16449:
--------------------------------------

Sorry, for the bad user experience. A lot of efforts went into the new SQL DDL 
and computed columns in the last release. Which also required a lot of 
refactoring and changes under hood. The {{connect()}} API has not been touched 
so far. However, we are planning to deprecate it and add to a new 
`createTable()` API in the near future once the DDL has settled. Your exception 
could be a bug or simply a wrong usage.

I don't know how the table source and it's descriptor are implemented. If they 
have a built-in watermarking and timestamps. You should use {{new 
Rowtime().timestampsFromSource().watermarksFromSource()}}. Esp. 
{{watermarksFromSource}} might be the missing piece why your code is not 
working. How about we use the DDL in these examples?

> Deprecated methods in the Table API walkthrough.
> ------------------------------------------------
>
>                 Key: FLINK-16449
>                 URL: https://issues.apache.org/jira/browse/FLINK-16449
>             Project: Flink
>          Issue Type: Improvement
>          Components: Quickstarts, Table SQL / API
>    Affects Versions: 1.10.0
>            Reporter: Marta Paes Moreira
>            Assignee: Robert Metzger
>            Priority: Minor
>         Attachments: 1.png
>
>
> The sample code provided for the Table API walkthrough [1] includes methods 
> that have been deprecated in Flink 1.10 (FLIP-64): registerTableSource, 
> registerTableSink, scan.
> This can be confusing to users trying to get started, also because finding 
> how to use the alternative methods is not very intuitive.
> [1] 
> [https://ci.apache.org/projects/flink/flink-docs-release-1.10/getting-started/walkthroughs/table_api.html]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to