Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
Currently, ExecNodeConfig holds TableConfig instead of ReadableConfig for the configuration coming from the planner, because it's used by
CommonPythonUtil#getMergedConfig. This should be fixed, so that CommonPythonUtil#getMergedConfig cam use a ReadableConfig instead, and then we can pass the ExecNodeConfig which holds the complete view of Planner's TableConfig + the ExecNode's persistedConfig.
To achieve that the getMergedConfig methods of PythonConfigUtil must be changed, and also the temp solution in
PythonFunctionFactory#getPythonFunction must be changed as well:
if (config instanceof TableConfig) { PythonDependencyUtils.merge(mergedConfig, ((TableConfig) config).getConfiguration()); } else { PythonDependencyUtils.merge(mergedConfig, (Configuration) config); }
Attachments
Issue Links
- relates to
-
FLINK-26194 Deprecate unused options in TableConfig
- Closed
- links to