[ https://issues.apache.org/jira/browse/BEAM-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ankur Goenka reassigned BEAM-4067: ---------------------------------- Assignee: Ankur Goenka > 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)