Флинк КПП относятся к разделам кафка?

Question

поэтому я попытался найти его в документации Flink, но не нашел ответа.

У меня есть приложение Flink «Источник Kafka-> Операции-> Окно-> Приемник Kafka». Конфигурация контрольной точки:

1. интервал 10 секунд

2. около 30 МБ размера состояния

3. каждая контрольная точка занимает менее 1 секунды + -

4. EXCACLY_ONCE в конфигурации производителя kafka.

Когда я пытаюсь отправить задание с включенной контрольной точкой на topi c с 30+ разделами, контрольная точка успешна, но когда я запускаю тот же код (с теми же ресурсами и параллелизмом) на topi c (сток topi c), например, с 2 разделами, он продолжает терпеть неудачу (после достижения timeout).

Итак, я пытаюсь найти его, но не могу найти хорошего объяснения, связано ли количество разделов приемника kafka с контрольной точкой? если да, то как?