Re: flink 1.11.1 sql client 流式 join 出现预期之外的含 null 行

本问题最后可以归结到这个问题： 请问在 flink sql 中建立的多张表应当怎样分辨接收 kafka 传来的 canal-json？ 并且已经解决。 谢谢你的帮助 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink 1.11.1 sql client 流式 join 出现预期之外的含 null 行

可以把原始的计算结果打印出来，执行 set execution.result-mode=changelog (如果source有delete消息，可能会出现null值) LittleFall <1578166...@qq.com> 于2020年8月13日周四 下午3:33写道： > mysql 的建表语句 > use test; > create table base ( > id int primary key, > location varchar(20) > ); > create table stuff( > id int pri

flink 1.11.1 sql client 流式 join 出现预期之外的含 null 行

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