HDFS归档文件一直Inprogress

问题描述/异常栈

按照设定参数

SET
'TABLE_NAME.connector.hdfs.rollover.interval' = '60000';
SET
'TABLE_NAME.connector.hdfs.inactivity.interval' = '60000'

一些part，应该可以归档为正式文件了，但是如图所示，还是临时文件

解决方案

任务开启checkpoint

问题原因

Flink在做checkpoint时候，才会真正把文件rename。

作者：邓崃翔