问答 2024-07-26 来自:开发者社区

flink cdc 写代码的方式 接收数据-map操作-sink到表 是导入那个Maven依赖啊?

flink cdc 写代码的方式 接收数据-map操作-sink到表 是导入那个Maven依赖啊?

问答 2024-07-24 来自:开发者社区

flink有办法在flat_map中使用redis长链接吗?

flink有办法在flat_map中使用redis长链接吗?我现在用短连接,数据量大的时候会出现地址不够的问题,https://help.aliyun.com/zh/redis/support/what-do-i-do-if-the-cannot-assign-requested-address-error-is-returned-when-i-access-apsaradb-for-redis....

问答 2024-06-11 来自:开发者社区

获取Flink MAP类型中的entries数量

获取Flink MAP类型中的entries数量

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

Flink为啥不支持数据类型:ARRAY、MAP / MULTISET、ROW 不支持?

"Flink中HBase SQL 连接器(flink-connector-hbase_2.11) 为啥不支持数据类型:ARRAY、MAP / MULTISET、ROW ?https://nightlies.apache.org/flink/flink-docs-release-1.11/zh/dev/table/connectors/hbase.html另外这3种类型的需求处理思路是什么?"

问答 2023-11-30 来自:开发者社区

Flink 从kafka中消费到数据到map里每条转换json对象太耗时,有什么好的解决办法吗?

Flink 从kafka中消费到数据到map里每条转换json对象太耗时,繁忙100%,导致source反压,这种情况有什么好的解决办法吗?

文章 2023-10-11 来自:开发者社区

Flink---11、状态管理(按键分区状态(值状态、列表状态、Map状态、归约状态、聚合状态)算子状态(列表状态、广播状态))

                                                        &...

Flink---11、状态管理(按键分区状态(值状态、列表状态、Map状态、归约状态、聚合状态)算子状态(列表状态、广播状态))
问答 2023-09-19 来自:开发者社区

flink 使用MapState,我定义的对象里面包含了一些Map,序列化会报错,有什么办法嘛?

flink 使用MapState,我定义的对象里面包含了一些Map,List等集合,然后我如果新增字段的话就无法正常从savepoint恢复,序列化会报错,有什么办法嘛?

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

Flink CDC大佬们,map完之后延迟比较久才到keyby算子是什么问题啊?

Flink CDC大佬们,map完之后延迟比较久才到keyby算子是什么问题啊?

问答 2023-08-20 来自:开发者社区

大佬们,Flink map完之后延迟比较久才到keyby算子是什么问题啊?

大佬们,Flink map完之后延迟比较久才到keyby算子是什么问题啊?

问答 2023-08-20 来自:开发者社区

Flink CDC map reduce是什么意思啊?

Flink CDC map reduce是什么意思啊?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等