Hi LakeShen,
Maybe "Idle State Retention Time"[1] may help in your case.
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/query_configuration.html#idle-state-retention-time
LakeShen 于2020年1月16日周四 上午10:15写道：
> Hi community，now I am use flink sql inner join in my
Hi community，now I am use flink sql inner join in my code,I saw the flink
document, the flink sql inner join will keep both sides of the join input
in Flink’s state forever.
As result , the hdfs files size are so big , is there any way to clear the
sql join state?
Thanks to your reply.
