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~!

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~!

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'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

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

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

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

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.

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~!