Luochg created FLINK-29676: ------------------------------ Summary: unexpected correlate variable $cor262 in the plan Key: FLINK-29676 URL: https://issues.apache.org/jira/browse/FLINK-29676 Project: Flink Issue Type: Bug Reporter: Luochg
drop table if exists b_11_LAINDEXINFO; CREATE TABLE b_11_LAINDEXINFO ( `indexcalno` STRING, `indextype` STRING, `agentcode` STRING, `managecom` STRING not null, `t1` DECIMAL(12,2), PRIMARY KEY (indexcalno,indextype,agentcode) NOT ENFORCED ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://IP:Port/gxdb?useUnicode=true&characterEncoding=utf8&useSSL=false&useLegacyDatetimeCode=false&serverTimezone=UTC&allowPublicKeyRetrieval=true', 'username'='username', 'password'='password', 'table-name' = 'TABLE_1' ); -- This message was sent by Atlassian Jira (v8.20.10#820010)