flink程序的partition的数据是根据key进行hash发送到source里面嘛?

flink程序的source的并行度数小于topic的partition数时,partition的数据是根据key进行hash发送到source里面嘛?

Flink这种怎么看他们的hash键是哪个?

Flink这种怎么看他们的hash键是哪个?

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

Flink按主键hash 发往不同分区,我同事没实现,说是负载严重不均衡,不知道还有没有其他办法?

Flink按主键hash 发往不同分区,我同事没实现,说是负载严重不均衡,不知道还有没有其他办法,就是0分区一直没数据, 都发到2分区了,不知道怎么回事?

Flink CDC中hash分区都只分到了2个task,你这是测试数据不?

Flink CDC中hash分区都只分到了2个task,你这是测试数据不?

有大佬知道flink里面operator 的uid最终去hash的时候的规则吗测试的时候发现设置不了

有大佬知道flink里面operator 的uid最终去hash的时候的规则吗,我测试的时候发现设置了不同的uid最终会报uid的hash值冲突,很奇怪多sink的场景下

Flink CDC 请教个问题 pg 可不可以 强制 走 hash join 呢?

Flink CDC 请教个问题 pg 可不可以 强制 走 hash join 呢?

Flink operator 自动生成 hash 值因素有哪些

Flink operator 自动生成 hash 值因素有哪些

Flink 中每个 operator 是怎样生成 hash 值的?

Flink 中每个 operator 是怎样生成 hash 值的?

Flink 任务中为什么要为每个 operator 生成 hash 值?

Flink 任务中为什么要为每个 operator 生成 hash 值?

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载