[jira] [Created] (FLINK-20368) Supports custom operator name for Flink SQL

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-20368) Supports custom operator name for Flink SQL

Shang Yuanchun (Jira)
Danny Chen created FLINK-20368:
----------------------------------

             Summary: Supports custom operator name for Flink SQL
                 Key: FLINK-20368
                 URL: https://issues.apache.org/jira/browse/FLINK-20368
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / API
    Affects Versions: 1.12.0
            Reporter: Danny Chen


A request from USER mailing list from Kevin Kwon:

For SQLs, I know that the operator ID assignment is not possible now since the query optimizer may not be backward compatible in each release

But are DDLs also affected by this?

for example,

CREATE TABLE mytable (
  id BIGINT,
  data STRING
) with (
  connector = 'kafka'
  ...
  id = 'mytable'
  name = 'mytable'
)

and we can save all related checkpoint data




--
This message was sent by Atlassian Jira
(v8.3.4#803005)