问答 2024-04-22 来自:开发者社区

Flink暴露一个问题,使用这种方式加数据,不能指定hashMap大小,怎么办?

Flink暴露一个问题,使用这种方式加数据,不能指定hashMap大小?然后这个row又是内置的,我们要动态加入 500个字段,然后导致性能急剧下降,hashmap在不停地扩容原先能跑5万每秒,然后使用这个只能1000每秒,使用反射的话,也达不到5万,能达到2-3万多

问答 2024-02-25 来自:开发者社区

Flink CDC里 任务重启由rocksdb状态后端改为hashmap行不行呢?

Flink CDC里 任务重启由rocksdb状态后端改为hashmap行不行呢?

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

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

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

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注