[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
[ https://issues.apache.org/jira/browse/FLINK-35411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849336#comment-17849336 ] Zakelly Lan commented on FLINK-35411: - [~spoon-lz] sure, will do. Thanks for your volunteering. > Optimize wait logic in draining of async state requests > --- > > Key: FLINK-35411 > URL: https://issues.apache.org/jira/browse/FLINK-35411 > Project: Flink > Issue Type: Sub-task > Components: Runtime / State Backends, Runtime / Task >Reporter: Zakelly Lan >Assignee: Yanfei Lei >Priority: Major > > Currently during draining of async state requests, the task thread performs > {{Thread.sleep}} to avoid cpu overhead when polling mails. This can be > optimized by wait & notify. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
[ https://issues.apache.org/jira/browse/FLINK-35411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848833#comment-17848833 ] liuzhuo commented on FLINK-35411: - [~zakelly] I am very interested in changes related to FLIP-423. If you have a suitable issue, please call me. > Optimize wait logic in draining of async state requests > --- > > Key: FLINK-35411 > URL: https://issues.apache.org/jira/browse/FLINK-35411 > Project: Flink > Issue Type: Sub-task > Components: Runtime / State Backends, Runtime / Task >Reporter: Zakelly Lan >Assignee: Yanfei Lei >Priority: Major > > Currently during draining of async state requests, the task thread performs > {{Thread.sleep}} to avoid cpu overhead when polling mails. This can be > optimized by wait & notify. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
[ https://issues.apache.org/jira/browse/FLINK-35411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848812#comment-17848812 ] Zakelly Lan commented on FLINK-35411: - [~spoon-lz] Actually this is found by some our internal benchmarks and [~Yanfei Lei] have made a draft resolving this, still validating I forgot to assign this, sorry about that. And we have more work to do which I think maybe you are interested in getting involved. > Optimize wait logic in draining of async state requests > --- > > Key: FLINK-35411 > URL: https://issues.apache.org/jira/browse/FLINK-35411 > Project: Flink > Issue Type: Sub-task > Components: Runtime / State Backends, Runtime / Task >Reporter: Zakelly Lan >Priority: Major > > Currently during draining of async state requests, the task thread performs > {{Thread.sleep}} to avoid cpu overhead when polling mails. This can be > optimized by wait & notify. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
[ https://issues.apache.org/jira/browse/FLINK-35411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848456#comment-17848456 ] liuzhuo commented on FLINK-35411: - [~zakelly] I saw that this issue has not been assigned yet. The whole FLIP-425 seems to be a very complicated and difficult work. I also want to try to participate in it. > Optimize wait logic in draining of async state requests > --- > > Key: FLINK-35411 > URL: https://issues.apache.org/jira/browse/FLINK-35411 > Project: Flink > Issue Type: Sub-task > Components: Runtime / State Backends, Runtime / Task >Reporter: Zakelly Lan >Priority: Major > > Currently during draining of async state requests, the task thread performs > {{Thread.sleep}} to avoid cpu overhead when polling mails. This can be > optimized by wait & notify. -- This message was sent by Atlassian Jira (v8.20.10#820010)