[ https://issues.apache.org/jira/browse/FLINK-32586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lijie Wang reassigned FLINK-32586: ---------------------------------- Assignee: xingbe > Enable input locality in SimpleExecutionSlotAllocator > ----------------------------------------------------- > > Key: FLINK-32586 > URL: https://issues.apache.org/jira/browse/FLINK-32586 > Project: Flink > Issue Type: Improvement > Components: Runtime / Coordination > Affects Versions: 1.18.0 > Reporter: xingbe > Assignee: xingbe > Priority: Major > Fix For: 1.18.0 > > > At present, the AdaptiveBatchScheduler uses the > `SimpleExecutionSlotAllocator` to assign slot to execution, but it currently > lacks support for the capability of input locality, which may increase > unnecessary data transmission overhead. In this issue, we aim to enable the > `SimpleExecutionSlotAllocator` to support the input locality. -- This message was sent by Atlassian Jira (v8.20.10#820010)