采用source参数时，采用flink lookup join时报错java.lang.IllegalArgumentException: open() failed

[fatherfu]

打包放到flink lib目录下，flink建表语句 CREATE TABLE ipos_qtlsd (
Id bigint, pid bigint, tn_id bigint, djbh string, ydjh string, rq int, yyrq int, zddm string, lastchanged timestamp , proctime as PROCTIME(), PRIMARY KEY (Id) NOT ENFORCED ) COMMENT '前台零售单' WITH ( 'connector' = 'mysql-cdc', 'hostname' = '', 'port' = '3306', 'username' = '', 'password' = '', 'database-name' = 'ipos', 'table-name' = 'ipos_qtlsd', 'scan.startup.mode' = 'latest-offset', 'server-time-zone' = 'Asia/Shanghai' )

create table dim_shop_info ( shop_code String, shop_name String, busi_type String ) WITH ( 'connector' = 'clickhouse', 'url' = 'clickhouse://...:8123', 'username' = 'default', 'password' = '**', 'database-name' = 'default',
'table-name' = 'dim_shop_info',
'lookup.cache.max-rows' = '100',
'lookup.cache.ttl' = '10',
'lookup.max-retries' = '3'
);

lookupjoin语句： SELECT t1.Id , t1.pid , t1.tn_id , t1.zddm, t2.shop_name, t2.busi_type FROM ipos_qtlsd AS t1 LEFT JOIN dim_shop_info FOR SYSTEM_TIME AS OF t1.proctime as t2 on t1.zddm =t2.shop_code;

报错：

[fatherfu]

正常的left join 是没问题，但是采用lookup join就会失败

[liekkassmile]

source我们用的不多，没有去适配所有场景

	lrh

@.*** | 签名由网易邮箱大师定制

在2022年08月11日 @.***> 写道：

正常的left join 是没问题，但是采用lookup join就会失败

— Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you are subscribed to this thread.Message ID: @.***>