[
https://issues.apache.org/jira/browse/FLINK-29676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29676:
---------------------------
Description:
create two tables
{code:java}
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'
);
drop table if exists b_11_LACOMMISION;
CREATE TABLE b_11_LACOMMISION (
`id` BIGINT,
`agentcode` STRING,
`managecom` STRING,
`fyc` DECIMAL(12,2),
PRIMARY KEY (id) 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_2'
);
{code}
was:
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'
);
> 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
> Priority: Blocker
>
> create two tables
> {code:java}
> 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'
> );
> drop table if exists b_11_LACOMMISION;
> CREATE TABLE b_11_LACOMMISION (
> `id` BIGINT,
> `agentcode` STRING,
> `managecom` STRING,
> `fyc` DECIMAL(12,2),
> PRIMARY KEY (id) 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_2'
> );
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
