问答 2023-05-22 来自:开发者社区

向大佬们请教一个问题,FLInk 1.16版本中 维表缓存的用法,目前我这边遇到维表ttl后不会?

向大佬们请教一个问题,FLInk 1.16版本中 维表缓存的用法,目前我这边遇到维表ttl后不会更新数据问题 CREATE TABLE order_device_info_source ( order_id BIGINT, consume_date TIMESTAMP(0), upload_date TIMESTAMP(0), ...

问答 2023-04-26 来自:开发者社区

flink任务里面能用本地缓存吗(比如把数据存在HashMap里)?我把分库分表的表关系(如user

flink任务里面能用本地缓存吗(比如把数据存在HashMap里)?我把分库分表的表关系(如user0~user1000写到user表)缓存在HashMap里,把任务提交到集群环境后,HashMap打印出来发现是空的;在本地运行时是有值的

问答 2023-04-05 来自:开发者社区

flink 的缓存块的超时阈值怎么设置?

flink 的缓存块的超时阈值怎么设置?

问答 2023-01-16 来自:开发者社区

Flink这种背压怎么搞?先写入到kafka缓存 在从kafka拉出来到数据库?

Flink这种背压怎么搞?先写入到kafka缓存 在从kafka拉出来到数据库?

问答 2022-12-20 来自:开发者社区

Flink关联MySQL维表的缓存策略如何设置?

Flink关联MySQL维表的缓存策略如何设置?

问答 2022-09-27 来自:开发者社区

flink cdc有没有异步缓存的实现,解决binlog消失太快的问题

flink cdc有没有异步缓存的实现,解决binlog消失太快的问题

文章 2022-08-22 来自:开发者社区

Flink / Scala - ProcessFunction 之间共用缓存测试

一.引言Flink 开发中有如下场景,数据需要经过两次 ProcessFunction 处理,第一步 ProcessV1 的一些信息重复不想通过每条数据传输至 ProcessV2,这时便捷的方法时对 ProcessV1 需要存储的元素进行去重缓存,保证全局共用一份缓存,可以有效减少储存空间,下面分别尝试三种缓存方式:A.ValueState 缓存B.HashMapCache 缓存C.RedisC....

Flink / Scala - ProcessFunction 之间共用缓存测试
文章 2022-05-18 来自:开发者社区

Flink之DataSet语义注释、广播变量、分布式缓存及参数传递

(1)语义注释在 Flink批量数据处理过程中,往往传入函数的对象中可能含有很多字段,其中有些字段是Function计算会用到的,但有些字段在进入 Funciton后并没有参与到实际计算过程中。针对这种情况,Fink提出了语义注解的功能,将这些字段在Function中通过注解的形式标记出来,区分出哪些是需要参与函数计算的字段,哪些是直接输出的字段。Flink Runtime在执行算子过程中,会对....

问答 2021-12-08 来自:开发者社区

怎么使用Flink中的分布式缓存呀?

怎么使用Flink中的分布式缓存呀?

问答 2021-12-08 来自:开发者社区

Flink中的分布式缓存具体是怎样使用的啊?

Flink中的分布式缓存具体是怎样使用的啊?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注