Emanuele Cesena created BEAM-485:
------------------------------------
Summary: 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)
