大佬们,麻烦问一个flink sql的问题,我有一个fql语句,insert into c select a.no,a.name,b.age from tb1 a left join tb2 b on a.no = b.no,当我在tb1中insert一条数据时不会触发c新增数据,只有当我再在tb2中补下对应数据时才会在c中插入数据,请问我要怎么弄才能做到只要在tb1中插入数据就在c中插数据?因为集群01节点给了4个slot 前四个任务正常使用 数据也正常,然后创建第5个任务的时候 它运行在node02上面,结果就不出数据了,server 从5400手动指定的依次加1
tb2有数据,c不会更新,得等tb1有数据,c才会更新,你是不是弄反了(此答案整理自Flink CDC 社区)
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。