[
https://issues.apache.org/jira/browse/BEAM-485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438508#comment-15438508
]
Aljoscha Krettek commented on BEAM-485:
---------------------------------------
Hi [~ecesena], could you check whether this bug is still valid in the current
master version?
> 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
>
> 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)
