[
https://issues.apache.org/jira/browse/BEAM-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16459299#comment-16459299
]
Eugene Kirpichov commented on BEAM-4067:
----------------------------------------
Clarification: this should probably go through
https://issues.apache.org/jira/browse/BEAM-4209 and
https://issues.apache.org/jira/browse/BEAM-4130 .
As a result, with the hypothetical FlinkPortableTestRunner, p.run() would spin
up a local container with the Flink JobService, which in turn would spin up a
local Flink and run the pipeline against it.
> Add portable Flink test runner
> ------------------------------
>
> Key: BEAM-4067
> URL: https://issues.apache.org/jira/browse/BEAM-4067
> Project: Beam
> Issue Type: New Feature
> Components: runner-flink
> Reporter: Ben Sidhom
> Priority: Minor
>
> The portable Flink runner cannot be tested through the normal mechanisms used
> for ValidatesRunner tests because it requires a job server to be constructed
> out of band and for pipelines to be run through it. We should implement a
> shim that acts as a standard Java SDK Runner that spins up the necessary
> server (possibly in-process) and runs against it.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
