FlinkFlink KeyGroupRange {startKeyGroup=7,endKeyGroup=12} does not contain key group 45

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink KeyGroupRange {startKeyGroup=7,endKeyGroup=12} does not contain key group 45相关的知识,希望对你有一定的参考价值。

本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载。

文章目录


1.概述

我的key(维度字段)是动态的,存在map里面,我计算的时候直接把map清空了

我是一个对象传到汇聚里面的,也是对对象直接计算,然后我把维度字段置空了

就是在汇聚的过程中清理了对象的key值

报错如下 KeyGroupRange startKeyGroup=7,endKeyGroup=12 does not contain key group 45


以上是关于FlinkFlink KeyGroupRange {startKeyGroup=7,endKeyGroup=12} does not contain key group 45的主要内容,如果未能解决你的问题,请参考以下文章

FlinkFlink状态的缩放(rescale)与键组(Key Group)设计

FlinkFlink 1.13 编译

FlinkFlink 监控 Checkpoint

FlinkFlink 源码之快照

FlinkFlink 1.13 编译

FlinkFlink PipelineExecutor 体系