flinkflink 报错 key group from 44 to 45 does not contain 4
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了flinkflink 报错 key group from 44 to 45 does not contain 4相关的知识，希望对你有一定的参考价值。
文章目录
本文为博主九师兄（QQ:541711153 欢迎来探讨技术）原创文章，未经允许博主不允许转载。
1.概述
此问题和一个问题很相似：【Flink】Flink KeyGroupRange startKeyGroup=7,endKeyGroup=12 does not contain key group 45
使用如下代码运行时报错：
二次keyby的原因是为了解决数据倾斜问题,第一个keyby用来基于EventTime的翻滚窗口，第二个keyby使用了基于processTime的session窗口
DataStream stream = dataStream
.key以上是关于flinkflink 报错 key group from 44 to 45 does not contain 4的主要内容，如果未能解决你的问题，请参考以下文章
FlinkFlink状态的缩放（rescale）与键组（Key Group）设计
FlinkFlink kerberos 认证报错 while accessing user/group information via Hadoop utils
FLinkFlink 消费 kafka 消费组 死掉 Marking the coordinator dead for group 造成数据重复消费
FLinkFLink Mertic 冲突 导致 任务挂掉 Namecollision Group allready contains a mertics