Flink SQL query using a UDTAGG

Hi, I am using the SQL api on Flink 1.18 and I am trying to write a SQL query which uses a 'user-defined table aggregate function' (UDTAGG). However, the documentation [1] only includes a Table API example w

Flink SQL query with window-TVF fails

I am trying to run a window aggregation SQL query (on Flink 1.16) with Windowing TVF for a TUMBLE window with a size of 5 Milliseconds it seems Flink does not let a window size use a time unit smaller than seconds. Is that correct? (The documentation

Data type mapping

I am writing Flink applications in Java and I need to do data type conversions between SQL/Table `DataType` and `TypeInformation`. According to Flink's documentation, type mapping methods in TypeConversions

Re: Window aggregation fails after upgrading to Flink 1.15

AS pgcnt FROM TABLE > (TUMBLE(TABLE myTable, DESCRIPTOR(rowtime), INTERVAL '5' SECONDS)) WHERE > (p_userid <> 'User_6') GROUP BY window_start, window_end, userid > > > > -- > Best！ > Xuyang > > > At 2022-05-19 08:53:03, "Pouria Pi

Window aggregation fails after upgrading to Flink 1.15

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

Aggregation support in the Table API

I am using the Table api in Java to write queries with grouping/aggregation. The aggregations may use built-in functions or user defined aggregate functions. Therefore I am using the aggregate() method on a WindowGroupedTable. table.window(...) .groupBy(...) .aggregate(Expressions.call("

Re: Flink fails to load class from configured classpath using PipelineOptions

> .asList() > .noDefaultValue() > .withDescription( > "A semicolon-separated list of the classpaths to > package with the job jars to be sent to" > + " the cluster. These

Flink fails to load class from configured classpath using PipelineOptions

I am developing a Java application which uses UDFs on Flink 1.14. It uses PipelineOptions.JARS config to add jar files, containing UDF classes, dynamically to the user classpath in the main method; However the application fails to load UDF class from configured jar files at job launch time with and