what's meaning of the "true/false" from "groupy...select"?THANKS

The complete code is: https://paste.ubuntu.com/p/hpWB87kT6P/ The result is: 2> (true,1,diaper,4) 7> (true,3,rubber,2) 4> (true,1,beer,3) 7> (false,3,rubber,2) 7> (true,3,rubber,8) That's the meaning of true/false in the result after running the above code? Thanks for your help~!

A group window expects a time attribute for grouping in a stream environment.THANKS for your help

my code is: https://paste.ubuntu.com/p/gVGrj2V7ZF/ it complains A group window expects a time attribute for grouping in a stream environment. but the data already as time attribute, How to fix it? Thanks for your help.

The proctime attribute can only be appended to the table schema and not replace an existing field. Please move 'proctime(r_proctime)' to the end of the schema

Example from Document: https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/tableApi.html part: Join with Temporal Table Current Whole Code: https://paste.ubuntu.com/p/Jn3ChkNSpp/ Exception: Exception in thread "main" org.apache.flink.table.api.ValidationException: The pr

Strange time format output by flink

I'm trying flatAggregate, the whole code is bug free and as follows: https://paste.ubuntu.com/p/TM6n2jdZfr/ the result I get is: 8> (true,1,+1705471-09-26T16:50,+1705471-09-26T16:55,+1705471-09-26T16:54:59.999,4,1) 4> (true,3,+1705471-09-26T16:50,+1705471-09-26T16:55,+1705471-09-26T16:54:5

Flink+DDL读取kafka没有输出信息,但是kafka消费端有信息

是Flink1.12的，kafka消费端能读取到数据，但是下面的代码无法读取到数据，运行后没有报错也没有输出，求助，谢谢 import org.apache.flink.streaming.api.scala._ import org.apache.flink.table.api.{EnvironmentSettings, Table} import org.apache.flink.table.api.bridge.scala.StreamTableEnvironment import org.apache.flink.types.Row import org.apache.flin

Unknown call expression: avg(amount) when use distinct() in Flink,Thanks~!

I'm testing https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/tableApi.html the part "Distinct aggregation on over window"(Ctrl+f and search the whole above string in above link please) test code distinctaggregation3.java https://paste.ubuntu.com/p/7HJ9W3hVVN/ POJO needed

Unknown call expression: avg(amount) when use distinct() in Flink Thanks~!

I posted this question here. http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Unknown-call-expression-avg-amount-when-use-distinct-in-Flink-Thanks-td40905.html but my replies to it is now delivered,it's strange. Flink1.12 scala2.12 Could anyone help me? Thanks~!

Unknown call expression: avg(amount) when use distinct() in Flink Thanks~!

I posted this question here. http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Unknown-call-expression-avg-amount-when-use-distinct-in-Flink-Thanks-td40905.html but my later replies to it is NOT delivered,it's strange. Flink1.12 scala2.12 Could anyone help me? Thanks~!

Flink Scala UDF Register fail:java.lang.ClassNotFoundException

Hi All, I posted a question here: https://stackoverflow.com/questions/65965893/scala-udf-complainsjava-lang-classnotfoundexceptionin-flink-sql-client It's about scala udf to be registered into flink sql client. Could you help me? Thanks~!