Issue while migrating to flink 1.20.0 with Java 17 & Scala 2.12

2024-11-19 Thread Nitin Saini
Hello Flink Community, I am in the process of migrating my Flink jobs from version 1.20.0 with Java 17, but I am encountering some issues. {\"errors\":[\"org.apache.flink.runtime.rest.handler.RestHandlerException: Could not execute application.\\n\\tat org.apache.flink.runtime.webmonitor.handlers

Re:Re: Order data with OVER AGGREGATION functions.

2024-11-19 Thread Xuyang
Hi, Guillermo. Additional, if there is an 'ORDER BY' clause, a Sort node should theoretically appear in the execution plan. However, according to CALCITE-2798[1], it is possible for the inner 'ORDER BY' to be ignored during SQL parsing. [1] https://issues.apache.org/jira/browse/CALCITE-279