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

["Mika Naylor (Jira)" <ji...@apache.org>]

Mika Naylor created FLINK-39764:
-----------------------------------

             Summary: 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


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)