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

Remove dependency on experiments=beam_fn_api flag from PortableRunner

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: sdk-py-core
    • Labels:
      None

      Description

      The execution path of Python's PortableRunner depends on the experiments=beam_fn_api flag. This flag is set automatically but has been broken in the past, e.g. when the FlinkRunner was subclassed from the PortableRunner (BEAM-8037).

      We should get rid of the flag, as the only supported execution path for the PortableRunner is the BeamFnApi. Perhaps we can move the flag to the Dataflow runners which may still depend on it.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              mxm Maximilian Michels
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: