Flink diff 文件接收器连接(Table api 数据流 api)
Flink diff file sink connections (Table api datastream api)
在datastream api中我们有一个参数withInactivityInterval,它可以设置我们的可用间隔,直到文件关闭。
但是tableapi中没有这样的东西,如果我们到table的数据流暂停几秒,tableapi 将关闭文件,暂停后将开始一个新文件。有什么办法可以避免这种情况吗?
以及如何在 table api 中设置后缀?
确认tableapi目前实现,确实不支持设置inactivityInterval
我创建了一个jira问题,然后跟进,感谢您的反馈
https://issues.apache.org/jira/browse/FLINK-25484
我提交了一个pr,不出意外的话,1.15版本应该会支持
在datastream api中我们有一个参数withInactivityInterval,它可以设置我们的可用间隔,直到文件关闭。
但是tableapi中没有这样的东西,如果我们到table的数据流暂停几秒,tableapi 将关闭文件,暂停后将开始一个新文件。有什么办法可以避免这种情况吗?
以及如何在 table api 中设置后缀?
确认tableapi目前实现,确实不支持设置inactivityInterval
我创建了一个jira问题,然后跟进,感谢您的反馈 https://issues.apache.org/jira/browse/FLINK-25484
我提交了一个pr,不出意外的话,1.15版本应该会支持