Łukasz Gajowy created BEAM-3359: ----------------------------------- Summary: 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: Aljoscha Krettek 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)