gustavodemorais commented on code in PR #29226:
URL: https://github.com/apache/flink/pull/29226#discussion_r4525815031
##########
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPlannerImpl.scala:
##########
@@ -121,7 +121,11 @@ class FlinkPlannerImpl(
private def validate(sqlNode: SqlNode, validator: FlinkCalciteSqlValidator):
SqlNode = {
try {
- sqlNode.accept(new PreValidateReWriter(validator, typeFactory))
+ // Validating the same query twice with one validator leaves the
namespaces of set-semantic
+ // table arguments unvalidated, so the rewrite gets its own validator
(see FLINK-40694).
Review Comment:
```suggestion
// Create a new validator: the second validation with the same
validator breaks
// set-semantic table arguments.
```
--
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]
