flink 版本视图不触发水印导致流阻塞怎么办？
from case3_TOPIC_A a
left join cust_data FOR SYSTEM_TIME AS OF a.ts as b on a.cust = b.cust
left join view_case3_TOPIC_B FOR SYSTEM_TIME AS OF a.ts as c on a.cust = c.cust;
view_case3_TOPIC_B 是一个版本视图，现在的问题是如果view_case3_TOPIC_B 的数据不更新，
case3_TOPIC_A 即使有新数据，也不往外输出。
怎么才能做到 case3_TOPIC_A 有数据就会立马触发呢*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
eft join的语义下，case3_TOPIC_A有数据就会往外输出的，能否给一点更多的信息来帮助排查问题~ *来自志愿者整理的FLINK邮件归档
2021-12-02 15:42:48赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
