Тюнинг Флинк КПП - PullRequest
       7

Тюнинг Флинк КПП

0 голосов
/ 07 октября 2019

Я пытаюсь понять, как интерпретировать показатели контрольных точек, отображаемые моим приложением 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, кажется, только растет по контрольным точкам, и я думаю, что это влияет на производительность работы. Как я могу настроить это?

...