Hi, The partition-to-subtask assignment of is not locality aware.
There were discussions to expose functionality for custom user-defined assignment methods, which it might be possible to leverage that for a locality aware assignment. Unfortunately, this feature is not implemented, yet. The rrelated issue that tracks this feature is https://issues.apache.org/jira/browse/FLINK-8570. Cheers, Gordon -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
