This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push:
new 17b8d1fc8ad [hotfix] Fix the compiling issue
17b8d1fc8ad is described below
commit 17b8d1fc8adca7a5760fa5074850c89df35b3275
Author: Dian Fu <[email protected]>
AuthorDate: Fri Apr 8 15:09:28 2022 +0800
[hotfix] Fix the compiling issue
---
.../flink/table/planner/plan/nodes/exec/ExecNodeConfig.java | 12 +++++++++++-
1 file changed, 11 insertions(+), 1 deletion(-)
diff --git
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeConfig.java
b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeConfig.java
index b33396fbec0..ebfe752141b 100644
---
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeConfig.java
+++
b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeConfig.java
@@ -36,7 +36,7 @@ import java.util.Optional;
@Internal
public final class ExecNodeConfig implements ReadableConfig {
- private final ReadableConfig tableConfig;
+ private final TableConfig tableConfig;
private final ReadableConfig nodeConfig;
@@ -45,6 +45,16 @@ public final class ExecNodeConfig implements ReadableConfig {
this.tableConfig = tableConfig;
}
+ /**
+ * Return the {@link PlannerBase#getTableConfig()}.
+ *
+ * @return the {@link PlannerBase#getTableConfig()}.
+ */
+ @Deprecated
+ public TableConfig getTableConfig() {
+ return tableConfig;
+ }
+
@Override
public <T> T get(ConfigOption<T> option) {
return nodeConfig.getOptional(option).orElseGet(() ->
tableConfig.get(option));