CODEWITHSUNDEEP
apache-flink
korolkevichm
korolkevichm

Reputation: 45

Flink diff file sink connections (Table api datastream api)

In datastream api we have an argument withInactivityInterval, which can set our available interval until the file is closed.

But there is no such thing in the table api, and if our datastream to the table is suspended for a few seconds, the table api will close the file, and after a pause it will start a new one. Is there any way to avoid this?

And how we can set suffix in table api?

Upvotes: 0

Views: 96

Answers (2)

ChangLi
ChangLi

Reputation: 823

I have submitted a pr, if nothing else, it should be supported in version 1.15

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

Upvotes: 1

ChangLi
ChangLi

Reputation: 823

Confirmed the current implementation of table api， it really does not support setting inactivityInterval

I created a jira issue，then follow up, thanks for your feedback https://issues.apache.org/jira/browse/FLINK-25484

Upvotes: 1

Related Questions