fsk119 commented on code in PR #26553:
URL: https://github.com/apache/flink/pull/26553#discussion_r2097280147
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java:
##########
@@ -371,7 +374,14 @@ protected void addToSelectList(
final SqlBasicCall call = (SqlBasicCall) node;
final SqlOperator operator = call.getOperator();
- if (operator instanceof SqlWindowTableFunction) {
+ if (node instanceof SqlExplicitModelCall) {
+ // Convert it so that model can be accessed in planner.
SqlExplicitModelCall
+ // from parser can't access model.
+ SqlExplicitModelCall modelCall = (SqlExplicitModelCall) node;
+ return new SqlModelCall(modelCall);
+ }
+
+ if (operator instanceof SqlWindowTableFunction || operator instanceof
SqlMLTableFunction) {
Review Comment:
If it is not easy to add tests here, I perfer to add a TODO here and finish
this part later.
--
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]
