开发者社区> 问答> 正文

我从mysql读出来一个stream,想给他放到一个类似java的本地缓存里,让所有的线程都能读写,

能直接放caffeine里吗?我看flink介绍,可能会启动多个jvm,我在想放入caffeine会不会不行?要是不行,放哪里呢?就是一些基础数据,来数据时候,会根据来的id,去基础数据找name,想放本地缓存,这样不用每次读mysql了。就是程序加载时,我先从mysql直接读出来数据列表,按您说的放入算子状态,然后启动后,mysql数据有变化了,比如id对应的name改掉了,这时候同步工具会把变化同步到kafka,我还要监听kafka,然后把这个id对应的name也给改掉,改这个算子里的列表的某个值

展开
收起
游客3oewgrzrf6o5c 2022-06-22 10:52:08 609 0
1 条回答
写回答
取消 提交回答
  • flink算子状态,taskmanager共享,加载状态的时候设置ttl,binlog有类型,判断是不是u,然后改状态的值(此答案整理自【③群】Apache Flink China社区)

    2022-06-22 11:09:06
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
One Box: 解读事务与分析一体化数据库 HybridDB for MySQL 立即下载
One Box:解读事务与分析一体化数据库HybridDB for MySQL 立即下载
如何支撑HTAP场景-HybridDB for MySQL系统架构和技术演进 立即下载

相关镜像