Flink: StreamingFileSink.withRollingPolicy не работает

Question

Время ролловера, которое я установил, составляет 5 с, но оно не работает. Новый файл был создан за 10 с, 20 с или 30 с или более. Я не знаю, почему и как это работает. Время контрольной точки, которое я установил, составляет 60 с.

DefaultRollingPolicy.builder()
.withRolloverInterval(5000)
.withInactivityInterval(5000)
.build())

Answer 1

Не могли бы вы предоставить больше информации? Что это значит, что это не работает? Вы не видите никаких файлов, которые были зафиксированы, или у вас есть исключение? Кроме того, что вы имеете в виду «Новый файл был создан за 10, 20, 30 или более секунд?»

Первое, на что следует обратить внимание, это то, что файлы будут зафиксированы после завершения контрольной точки, поэтому, по крайней мере, после 60-е годы.