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)
