[
https://issues.apache.org/jira/browse/BEAM-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566051#comment-16566051
]
Ankur Goenka commented on BEAM-4067:
------------------------------------
This feature is implemented in https://github.com/apache/beam/pull/5935
> Java: FlinkPortableTestRunner: runs portably via self-started local Flink
> -------------------------------------------------------------------------
>
> Key: BEAM-4067
> URL: https://issues.apache.org/jira/browse/BEAM-4067
> Project: Beam
> Issue Type: New Feature
> Components: runner-flink
> Reporter: Ben Sidhom
> Assignee: Ankur Goenka
> 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)
