Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25217 FLIP-190: Support Version Upgrades for Table API & SQL Programs
  3. FLINK-26297

Introduce ExecutionNodeConfig which will be used in all Exec Nodes

    XMLWordPrintableJSON

Details

    Description

      Introduce ExecutionNodeConfig to be used instead of planner.getConfiguration()

      and planner.getTableConfig(), as a first step, to facilitate a merged configuration, combining

      the persisted configuration of the ExecNodes with the one coming from the environment.

      This is also a prerequisite to solve various issues with configuration that is not propagated from flink-conf.yaml all the way down to operators.

      Attachments

        Issue Links

          Activity

            People

              matriv Marios Trivyzas
              matriv Marios Trivyzas
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: