You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Luochg (Jira)" <ji...@apache.org> on 2022/10/18 07:48:00 UTC
[jira] [Updated] (FLINK-29676) unexpected correlate variable $cor262 in the plan

     [ 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)