Ben Sidhom created BEAM-3672:
--------------------------------
Summary: FlinkRunner: Implement an Artifact service using the
Flink DistributedCache
Key: BEAM-3672
URL: https://issues.apache.org/jira/browse/BEAM-3672
Project: Beam
Issue Type: Sub-task
Components: runner-flink
Reporter: Ben Sidhom
Assignee: Aljoscha Krettek
We need to have a DistributedCache-based artifact service to ship with the
portable Flink runner. The DistributedCache is a perfect fit for Flink because
it comes for free and is the mechanism that Flink already uses to distribute
its own artifacts.
The final artifact service implementation should be pluggable, but using the
DistributedCache allows the Flink runner to work without additional external
dependencies (beyond perhaps Docker).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
