[
https://issues.apache.org/jira/browse/FLINK-39764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-39764:
-----------------------------------
Labels: pull-request-available (was: )
> Support dynamic table options in Table API
> ------------------------------------------
>
> Key: FLINK-39764
> URL: https://issues.apache.org/jira/browse/FLINK-39764
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
> Reporter: Mika Naylor
> Assignee: Mika Naylor
> Priority: Major
> Labels: pull-request-available
>
> Currently, if you wish to use dynamic table options to override specific
> table options (for example, 'scan.startup.mode') you can only do this through
> the SQL api, via hints:
>
> {code:java}
> select id, name from kafka_table1 /*+
> OPTIONS('scan.startup.mode'='earliest-offset') */; {code}
> A table API user that wishes to use dynamic options thus is unable to,
> without dropping into {{tenv.executeSql }}and more or less negating the use
> of the Table API. It would be nice if Table API users could specify these
> extra options when getting a table, something like:
> {code:java}
> tEnv.from("kafka_table1", Map.of("scan.startup.mode", "earliest-offset"))
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
