You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/06 11:07:00 UTC

[jira] [Created] (FLINK-9542) ExEnv#registerCachedFile should accept Path

Chesnay Schepler created FLINK-9542:
---------------------------------------

             Summary: ExEnv#registerCachedFile should accept Path
                 Key: FLINK-9542
                 URL: https://issues.apache.org/jira/browse/FLINK-9542
             Project: Flink
          Issue Type: Improvement
          Components: DataSet API, DataStream API
            Reporter: Chesnay Schepler


Currently, {{registerCachedFile}} accepts {{Strings}} as file-paths.

This is undesirable because invalid paths are detected much later than necessary; at the moment this happens when we attempt to upload them to the blob store, i.e. during job submission, when ideally it should fail right away.

As an intermediate solution we can modify the {{DistributedCacheEntries}} to contain {{Paths}} instead of {{Strings}}. This will not require API changes but still allow earlier detection.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)