Zakelly Lan created FLINK-37107:
-----------------------------------

             Summary: Allow buffer overdraft in async state processing
                 Key: FLINK-37107
                 URL: https://issues.apache.org/jira/browse/FLINK-37107
             Project: Flink
          Issue Type: Sub-task
            Reporter: Zakelly Lan
            Assignee: Zakelly Lan


In FLINK-37089, we resolved the deadlock of derived requests waiting on 
draining current request, when user call `asyncProcessWithKey`. However, we 
also found the timer may also suffer from this problem. Thus I suggest a buffer 
overdraft for all those derived requests, to resolve the deadlock when there is 
a single hotspot key and all the requests queue in line while there comes a 
derived with same key cannot properly queue in a full buffer.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to