[jira] [Resolved] (BEAM-485) Can't set Flink runner in code

["Daniel Halperin (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Daniel Halperin resolved BEAM-485.
----------------------------------
       Resolution: Pending Closed
    Fix Version/s: Not applicable

(Pending closed, with 3+ months of no user feedback)

> Can't set Flink runner in code
> ------------------------------
>
>                 Key: BEAM-485
>                 URL: https://issues.apache.org/jira/browse/BEAM-485
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>            Reporter: Emanuele Cesena
>             Fix For: Not applicable
>
>
> Calling:
> options.setRunner(FlinkRunner.class);
> doesn't seem to properly set the runner.
> Running --runner=FlinkRunner from the command line works.
> Both approaches were working on 0.1.0, but options.setRunner doesn't seem to work on master anymore.
> I noticed there are tests that only cover the command line case:
> https://github.com/apache/incubator-beam/blob/master/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/FlinkRunnerRegistrarTest.java



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)