[jira] [Assigned] (BEAM-3359) Unable to change "flinkMaster" from "[auto]" in TestFlinkRunner
[ https://issues.apache.org/jira/browse/BEAM-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned BEAM-3359: -- Assignee: Dawid Wysakowicz > Unable to change "flinkMaster" from "[auto]" in TestFlinkRunner > --- > > Key: BEAM-3359 > URL: https://issues.apache.org/jira/browse/BEAM-3359 > Project: Beam > Issue Type: Bug > Components: runner-flink >Reporter: Łukasz Gajowy >Assignee: Dawid Wysakowicz >Priority: Minor > > In TestFlinkRunner's constructor there is a line like this: > {{options.setFlinkMaster("\[auto\]");}} > which basically ignores any "flinkMaster" provided earlier (eg. using command > line) leading to errors that are hard to find (for example wondering: "i > provided good url in pipeline options... why is it not connecting to my > cluster?). > Setting a {{@Default.String("\[auto\]")}} in FlinkPipelineOptions could be > one solution I guess. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (BEAM-3359) Unable to change "flinkMaster" from "[auto]" in TestFlinkRunner
[ https://issues.apache.org/jira/browse/BEAM-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned BEAM-3359: -- Assignee: (was: Aljoscha Krettek) > Unable to change "flinkMaster" from "[auto]" in TestFlinkRunner > --- > > Key: BEAM-3359 > URL: https://issues.apache.org/jira/browse/BEAM-3359 > Project: Beam > Issue Type: Bug > Components: runner-flink >Reporter: Łukasz Gajowy >Priority: Minor > > In TestFlinkRunner's constructor there is a line like this: > {{options.setFlinkMaster("\[auto\]");}} > which basically ignores any "flinkMaster" provided earlier (eg. using command > line) leading to errors that are hard to find (for example wondering: "i > provided good url in pipeline options... why is it not connecting to my > cluster?). > Setting a {{@Default.String("\[auto\]")}} in FlinkPipelineOptions could be > one solution I guess. -- This message was sent by Atlassian JIRA (v6.4.14#64029)