matriv commented on a change in pull request #19187:
URL: https://github.com/apache/flink/pull/19187#discussion_r831177587
##########
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelOptUtil.scala
##########
@@ -200,8 +200,7 @@ object FlinkRelOptUtil {
/** Get max cnf node limit by context of rel */
def getMaxCnfNodeCount(rel: RelNode): Int = {
- val tableConfig = getTableConfigFromContext(rel)
-
tableConfig.getConfiguration.getInteger(FlinkRexUtil.TABLE_OPTIMIZER_CNF_NODES_LIMIT)
+
getTableConfigFromContext(rel).get(FlinkRexUtil.TABLE_OPTIMIZER_CNF_NODES_LIMIT)
Review comment:
I think this is irrelevant for the change, I'm planning to cherry-pick
commits from: https://github.com/apache/flink/pull/18925 and
https://github.com/apache/flink/pull/18908
and do some further cleanup
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
