[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[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