[jira] [Created] (FLINK-15938) Idle state not cleaned in StreamingJoinOperator and StreamingSemiAntiJoinOperator

[Shang Yuanchun (Jira)]

Benchao Li created FLINK-15938:
----------------------------------

             Summary: Idle state not cleaned in StreamingJoinOperator and StreamingSemiAntiJoinOperator
                 Key: FLINK-15938
                 URL: https://issues.apache.org/jira/browse/FLINK-15938
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Planner
    Affects Versions: 1.9.2, 1.10.0
            Reporter: Benchao Li


{code:java}
return StateTtlConfig
   .newBuilder(Time.milliseconds(retentionTime))
   .setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)
   .setStateVisibility(StateTtlConfig.StateVisibility.ReturnExpiredIfNotCleanedUp)
   .build();
{code}
StateTtl is constructed in above code for `StreamingJoinOperator` and `StreamingSemiAntiJoinOperator`.

However, as stated in [https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/state/state.html#cleanup-of-expired-state] , the state will be cleaned only when it's read which means the state will not be cleaned enless we read it.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)