flink keyby 之后，不同的 key 分到了同一个子任务中。如果我要基于 keyState 的值进行累加，该如何处理这种情况呢？
成为第一个点赞的人吧 
如果觉得我的文章对您有用，请随意打赏。你的支持将鼓励我继续创作！
请使用微信扫描二维码。
作者：张浩
- GitHub
- 城市
张浩 的其他话题
- flink 消费 kafka 数据 如何保证同一分区的顺序一致性？
- flink 在处理数据流中两条数据时，第一条数据处理完成，会有延迟一段时间再去处理下一条数据。请问采用什么方式避免这种情况？
- flink 写入 Redis 偶尔会出现 broken pipe ?
- flink keyby 之后，不同的 key 分到了同一个子任务中。如果我要基于 keyState 的值进行累加，该如何处理这种情况呢？
- flink:keyedprocessfuction 添加 state 后,报 Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy/failureRateRestart？
- flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？
- flink key by 后的 process 不执行？
- spark 写入 Excel 问题 ？
分类下其他主题
- 现在问不了问题？
- 请问 hadoop 组件中的 hadoop 是安装在 /opt 下还是 /usr/local 下？
- HDFS 动态增加节点每次都要重启实验才行是为什么？
- MR 任务将数据写入 ORC 文件中，数据采用竖杠（|）进行分割，这个数据分割怎么设置？？希望大牛解答谢谢！！
- 为什么 hive 初始化 MySQL 出错？
- 为什么安装 datanode 出错？
- hadoop 为什么我没有在 public 下面找到 jdk 安装包？
- flink 的 standalone 模式部署后，Web 界面上，显示 taskmanager：0，total task slots：0，请问这个是怎么回事呢？
QQ群1：551936262
关注海汼部落技术社区
