[ https://issues.apache.org/jira/browse/FLINK-17892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114482#comment-17114482 ]
Jingsong Lee commented on FLINK-17892: -------------------------------------- Hi [~hailong wang], thanks for reporting. Do you mean the KAFKA source will be reused in physical graph? And random pick one dynamic option? If it is, this should be a noteworthy bug. CC: [~danny0405] > Dynamic option may not be a part of the table digest > ---------------------------------------------------- > > Key: FLINK-17892 > URL: https://issues.apache.org/jira/browse/FLINK-17892 > Project: Flink > Issue Type: Improvement > Components: Table SQL / Planner > Affects Versions: 1.11.0 > Reporter: hailong wang > Priority: Major > Fix For: 1.12.0 > > > For now, Table properties not be a part of table digest, but dynamic option > will be included. > This will lead to an error when plan reused. > if I defines a kafka table: > {code:java} > CREATE TABLE KAFKA ( > …… > ) with ( > topic = 'xx', > groupid = 'xxx' > …… > ) > Insert into sinktable select * from KAFKA; > Insert into sinktable1 select * from KAFKA;{code} > KAFKA source will be reused according to the SQL above. > But if i add different table hint to dml, like: > {code:java} > Insert into sinktable select * from KAFKA /*+ OPTIONS('k1' = 'v1')*/; > Insert into sinktable1 select * from KAFKA /*+ OPTIONS('k2' = 'v2')*/; > {code} > There will be two kafka tableSources use the same groupid to consumer the > same topic. > So I think dynamic option may not be a part of the table digest. -- This message was sent by Atlassian Jira (v8.3.4#803005)