Flink：StreamingFileSink.withRollingPolicy 不起作用

Question

我设置的滚动时间为5s，但不起作用。新文件是在10秒、20秒、30秒或更长时间内创建的。我不知道为什么和如何工作。我设置的检查点时间是60秒。

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

Answer 1

您能提供更多信息吗？它不起作用是什么意思？您看不到任何正在提交的文件，或者您有异常？你的意思是"新文件是在10秒、20秒、30秒或更长时间内创建的"？

首先要注意的是，文件将在检查点完成后提交，至少在60年代之后。