我从mysql读出来一个stream，想给他放到一个类似java的本地缓存里，让所有的线程都能读写，
能直接放caffeine里吗？我看flink介绍，可能会启动多个jvm，我在想放入caffeine会不会不行？要是不行，放哪里呢？就是一些基础数据，来数据时候，会根据来的id，去基础数据找name，想放本地缓存，这样不用每次读mysql了。就是程序加载时，我先从mysql直接读出来数据列表，按您说的放入算子状态，然后启动后，mysql数据有变化了，比如id对应的name改掉了，这时候同步工具会把变化同步到kafka，我还要监听kafka，然后把这个id对应的name也给改掉，改这个算子里的列表的某个值
展开
收起
1
条回答
写回答
写回答
-
flink算子状态，taskmanager共享，加载状态的时候设置ttl，binlog有类型，判断是不是u，然后改状态的值（此答案整理自【③群】Apache Flink China社区）
2022-06-22 11:09:06赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
