Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-8336

Make dockerized job server image configurable

Details

    Description

      I'd also argue that having PortableRunner bring up a Flink job server by default is unexpected behavior, but touching that would be a breaking change.

      It might be good to move some of this logic to Python's FlinkRunner class so we can have runner-specific defaults.

      https://github.com/apache/beam/blob/c5f43342f914fc8ff367b86fb9294c38436ed3ce/sdks/python/apache_beam/runners/portability/job_server.py#L252-L254

      Attachments

        Issue Links

          Activity

            People

              ibzib Kyle Weaver
              ibzib Kyle Weaver
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: