This is an automated email from the ASF dual-hosted git repository.
philo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 7773857c0d [GLUTEN-10630][FLINK] Support processing time for q12
(#10631)
7773857c0d is described below
commit 7773857c0de3467023ec24eb5cd43328513e15be
Author: shuai.xu <[email protected]>
AuthorDate: Wed Sep 10 10:57:16 2025 +0800
[GLUTEN-10630][FLINK] Support processing time for q12 (#10631)
---
.../src/main/java/org/apache/gluten/rexnode/WindowUtils.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/gluten-flink/planner/src/main/java/org/apache/gluten/rexnode/WindowUtils.java
b/gluten-flink/planner/src/main/java/org/apache/gluten/rexnode/WindowUtils.java
index 29cd64c30b..6f7a64f6f4 100644
---
a/gluten-flink/planner/src/main/java/org/apache/gluten/rexnode/WindowUtils.java
+++
b/gluten-flink/planner/src/main/java/org/apache/gluten/rexnode/WindowUtils.java
@@ -63,8 +63,10 @@ public class WindowUtils {
throw new RuntimeException("Not support window spec " + windowSpec);
}
- if (windowing instanceof TimeAttributeWindowingStrategy &&
windowing.isRowtime()) {
- rowtimeIndex = ((TimeAttributeWindowingStrategy)
windowing).getTimeAttributeIndex();
+ if (windowing instanceof TimeAttributeWindowingStrategy) {
+ if (windowing.isRowtime()) {
+ rowtimeIndex = ((TimeAttributeWindowingStrategy)
windowing).getTimeAttributeIndex();
+ }
windowType = 0;
} else if (windowing instanceof WindowAttachedWindowingStrategy) {
rowtimeIndex = ((WindowAttachedWindowingStrategy)
windowing).getWindowEnd();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
