流表在与维表join时，维表没有动态查询
您好，我在做流式数据处理时，需要用到外部数据（mysql）关联，进行处理，但是发现只是在第一个窗口数据处理时，才会去查mysql，第二个窗口查询时，没有再次查询mysql数据，而是用的第一次查询的mysql数据。 PS:mysql数据是随时更新的，所以希望每个窗口的流式数据都去查一次最新的mysql数据,进行关联处理 下图是打印的log,在第二个窗口数据打印之前，我认为应该先会再去查一次mysql数据并打印，但是发现并没有
非常感谢查收和回复 谢谢*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
你好，我理解继承RichSourceFunction实现的mysql，只会读一次mysql（你应该是参考JDBCSinkFunction的实现？），并不能实现维表的功能。在1.9发布后你可以使用LookupableTableSource来实现维表，发布之前可以考虑自己用UDTF来实现。*来自志愿者整理的flink
2021-12-07 16:37:23赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
