ibis icon indicating copy to clipboard operation
ibis copied to clipboard

fix(flink): fix compilation of over aggregation query in flink backend

Open chloeh13q opened this issue 1 year ago • 0 comments
trafficstars

Description of changes

This PR fixes the compilation of over aggregation query in Flink backend.

I identified the following issues:

  1. The interval time value is not compiled with the appropriate precision. ibis.interval(minutes=500) compiles to `INTERVAL '500' MINUTE, which throws
org.apache.calcite.sql.validate.SqlValidatorException: Interval field value 500 exceeds precision of MINUTE(2) field
  1. range=(-ibis.interval(minutes=500), 0) compiles to [...] AND CAST(0 AS INTERVAL MINUTE) following and Flink doesn't support rows/range following in over aggregation. This throws
org.apache.flink.table.api.TableException: OVER RANGE FOLLOWING windows are not supported yet.

I also removed the unused test snapshot directory that didn't get cleaned up.

Issues closed

chloeh13q avatar Feb 14 '24 20:02 chloeh13q