[jira] [Updated] (FLINK-39764) Support dynamic table options in Table API

["ASF GitHub Bot (Jira)" <ji...@apache.org>]

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