Flink diff 文件 sink 连接（Table api datastream api）答案

【问题标题】：Flink diff file sink connections (Table api datastream api)Flink diff 文件 sink 连接（Table api datastream api）
【发布时间】：2021-12-15 07:19:11
【问题描述】：

在datastream api 中我们有一个参数withInactivityInterval，它可以设置我们的可用间隔，直到文件关闭。

但是table api中没有这个东西，如果我们到table的数据流暂停几秒钟，table api就会关闭文件，暂停后会开始一个新的。有什么办法可以避免吗？

以及如何在table api中设置后缀？

【问题讨论】：

标签： apache-flink

【解决方案1】：

我已经提交了一个pr，如果没有别的，应该在1.15版本支持

https://github.com/apache/flink/pull/18359

【讨论】：

【解决方案2】：

确认当前table api的实现，确实不支持设置inactivityInterval

我创建了一个jira issue，然后跟进，感谢您的反馈 https://issues.apache.org/jira/browse/FLINK-25484

【讨论】：