Kyle Weaver created BEAM-6725:
---------------------------------
Summary: Move runner-agnostic code out of FlinkJobInvocation
Key: BEAM-6725
URL: https://issues.apache.org/jira/browse/BEAM-6725
Project: Beam
Issue Type: Task
Components: runner-flink, runner-samza, runner-spark
Reporter: Kyle Weaver
Assignee: Kyle Weaver
Like BEAM-6714, FlinkJobInvocation contains some code (for asynchronously
running jobs) that isn't really Flink specific and therefore could/should be
reused by other portable runners. I'm thinking instead of an interface,
JobInvocation should be made an abstract class that implements the methods that
it currently abstracts, with an abstract method `runPipeline` for the
runner-specific details.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
