[
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)