{
"emoji": "👍",
"version": 1
}
Hi, Shiyuan.
The current mailing list primarily focuses on user issues.
For discussions related to the new flip, please move to the dev mailing list[1].
[1] d...@flink.apache.org
--
Best！
Xuyang
At 2024-11-14 11:00:40, "Linda Li" wrote:
Hi,
Starting a thread for addin
Hi,
Starting a thread for adding Flink UDF metrics.
UDFs are widely used by Flink user, but they introduce significant
challenges when it comes to debugging and performance optimization. UDFs
often act as black boxes, making it difficult to trace issues or identify
the root causes of failures,
Hi,
I have a very basic window function that finds minimum and maximum values on a
keyed stream.
```
package org.example
import org.apache.flink.streaming.api.scala.function.ProcessWindowFunction
import org.apache.flink.streaming.api.windowing.windows.TimeWindow
import org.apache.flink.util.Col
Thank you for your answer. I put the lib in that directory. I could say
that it's right because if I choose a wrong type of source I get the next
message:
Flink SQL> select * from blacklist;
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Could not
