Stephan Ewen created FLINK-19218:
------------------------------------
Summary: Remove inconsistent host logic for LocalFileSystem
Key: FLINK-19218
URL:
https://issues.apache.org/jira/browse/FLINK-19218 Project: Flink
Issue Type: Bug
Components: API / Core
Affects Versions: 1.11.1
Reporter: Stephan Ewen
Assignee: Stephan Ewen
Fix For: 1.12.0
The {{LocalFileSystem}} returns file splits with a host information as returned via
{code}
InetAddress.getLocalHost().getHostName();
{code}
This might be different, though, from the host name that the TaskManager is configured to use, which results in incorrect location matching if this information is used.
It is also incorrect in cases where the file system is in fact not local, but a mounted NAS.
Since this information is anyways not useful (there no good way to support locality-aware file access for the LocalFileSystem) I would suggest to remove this code. That would be better than having code in place that tries to suggest locality information that is frequently incorrect.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)