flink:streamingfilesink.withrollingpolicy doesn不起作用

63lcw9qa  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(398)

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

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

tvokkenx1#

你能提供更多的信息吗?它不工作是什么意思?您看不到正在提交的任何文件,或者有异常?另外,“新文件是在10秒、20秒、30秒或更长时间内创建的”是什么意思?
首先要注意的是,文件将在检查点完成后提交,所以至少在60年代之后。

相关问题