Re: Window aggregation fails after upgrading to Flink 1.15

2022-05-23 Thread Shengkai Fang
Glad to see you find the root cause. I think we can shade the janino dependency if it influences the usage. WDYT, godfrey? Best, Shengkai Pouria Pirzadeh 于2022年5月21日周六 00:59写道: > Thanks for help; I digged into it and the issue turned out to be the > version of Janino: > flink-table has pinned

Re: Window aggregation fails after upgrading to Flink 1.15

2022-05-20 Thread Pouria Pirzadeh
Thanks for help; I digged into it and the issue turned out to be the version of Janino: flink-table has pinned Janino's version to 3.011 as that is the version Calcite is using; However due to other dependencies in my project, at runtime application code had ended up using a newer version of Janino

Window aggregation fails after upgrading to Flink 1.15

2022-05-18 Thread Pouria Pirzadeh
I am running a Flink application in Java that performs window aggregation. The query runs successfully on Flink 1.14.4. However, after upgrading to Flink 1.15.0 and switching the code to use Windowing TVF, it fails with a runtime error as planner can not compile and instantiate window Aggs Handler