Я пытаюсь понять, как интерпретировать показатели контрольных точек, отображаемые моим приложением Flink, и настраивать их. В пользовательском интерфейсе Flink я вижу число порядка 100 МБ для столбца Buffered during Alignment
на вкладке «Контрольные точки» для одного из операторов (оператор окна). Из документов я вижу
The amount of data buffered during alignments. For exactly-once semantics, Flink aligns the streams at operators that receive multiple input streams, buffering some data for that alignment. The buffered data volume is ideally low - higher amounts means that checkpoint barriers are received at very different times from the different input streams.
Что означает checkpoint barriers received at very different times mean
? Число Buffered during alignment
, кажется, только растет по контрольным точкам, и я думаю, что это влияет на производительность работы. Как я могу настроить это?