mysql 的建表语句
use test;
create table base (
id int primary key,
location varchar(20)
);
create table stuff(
id int primary key,
b_id int,
name varchar(20)
);
flink sql client 的建表语句
create table base (
id int primary key,
location varchar(20)
)WITH (
'connector' = 'kafka',
'topic' = 'example',
'properties.group.id' = 'testGroup',
'scan.startup.mode' = 'latest-offset',
'properties.bootstrap.servers' = 'localhost:9092',
'format' = 'canal-json'
);
create table stuff(
id int primary key,
b_id int,
name varchar(20)
)WITH (
'connector' = 'kafka',
'topic' = 'example',
'properties.group.id' = 'testGroup',
'scan.startup.mode' = 'latest-offset',
'properties.bootstrap.servers' = 'localhost:9092',
'format' = 'canal-json'
);
flink 查询语句
select distinct stuff.id s_id, base.id b_id, base.location, stuff.name
from stuff inner join base
on stuff.b_id = base.id;
mysql 插入语句
insert into base values (1, 'beijing');
insert into stuff values (1, 1, 'zz');
flink 结果
<http://apache-flink.147419.n8.nabble.com/file/t858/2020-08-13_15-12-36_%E7%9A%84%E5%B1%8F%E5%B9%95%E6%88%AA%E5%9B%BE.png>
mysql 执行同样的查询的结果：
+------+------+----------+------+
| s_id | b_id | location | name |
+------+------+----------+------+
| 1 | 1 | beijing | zz |
+------+------+----------+------+
1 row in set (0.01 sec)
而且有时候连结果正确的行都不会出现，只会出现含 null 的行。
求助大家。。。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
