Flink InternalTimeServiceManager localKeyGroupRange

Question

1. В InternalTimeServiceManager, где находится localKeyGroupRange инициализируется? И это происходит при запуске диспетчера задач?

   InternalTimeServiceManager( int totalKeyGroups, KeyGroupsList localKeyGroupRange, KeyContext keyContext, ProcessingTimeService processingTimeService) { Preconditions.checkArgument(totalKeyGroups > 0); this.totalKeyGroups = totalKeyGroups; this.localKeyGroupRange = Preconditions.checkNotNull(localKeyGroupRange);

2. из-за значения localKeyGroupRange неизвестно, перепутано в ex:

   java.lang.IllegalArgumentException: Key Group 91 does not belong to the local range.

   Любая идея будет оценена.