xuyangzhong commented on code in PR #23505:
URL: https://github.com/apache/flink/pull/23505#discussion_r1453279807
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecWindowTableFunction.java:
##########
@@ -77,6 +79,11 @@ protected CommonExecWindowTableFunction(
@Override
protected Transformation<RowData> translateToPlanInternal(
PlannerBase planner, ExecNodeConfig config) {
+ if (windowingStrategy.getWindow() instanceof SessionWindowSpec) {
+ // TODO introduce session window tvf op instead of falling back to
group window
Review Comment:
When session window table function does not hit the optimization
`PullUpWindowTableFunctionIntoWindowAggregateRule`, this exception will be
thrown.
I have linked a JIRA about TODO in the code. You can see more here
https://issues.apache.org/jira/browse/FLINK-34100.
--
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]
