[BEAM-3359] Unable to change "flinkMaster" from "[auto]" in TestFlinkRunner

• Type: Bug
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 2.7.0
• Component/s: runner-flink
• Assignee: Dawid Wysakowicz
• Reporter: Lukasz Gajowy
• Created: 15/Dec/17 12:56
• Updated: 24/Jul/20 20:13
• Resolved: 13/Aug/18 11:52

Description

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.

Issue Links

• blocks: BEAM-4465 Enable Flink runner to run IOITs