beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Davor Bonaci (JIRA)" <>
Subject [jira] [Created] (BEAM-1628) Flink runner: logic around --flinkMaster is error-prone
Date Mon, 06 Mar 2017 01:36:33 GMT
Davor Bonaci created BEAM-1628:

             Summary: Flink runner: logic around --flinkMaster is error-prone
                 Key: BEAM-1628
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Davor Bonaci
            Assignee: Aljoscha Krettek
            Priority: Minor

The logic for handling {{--flinkMaster}} seems not particularly user-friendly.

    if (masterUrl.equals("[local]")) {
    } else if (masterUrl.equals("[collection]")) {
    } else if (masterUrl.equals("[auto]")) {
    } else if (masterUrl.matches(".*:\\d*")) {
    } else {
      // use auto.

The options are constructed with "auto" set as default.

I think we should do the following:
* I assume there's a default port for the Flink master. We should default to it.
* We should treat a string without a colon as a host name. (Not default to local execution.)

This is super easy fix, hopefully someone can pick it up quickly ;-)

This message was sent by Atlassian JIRA

View raw message