Confirmation on Lambda Support for UDFs in FlinkSQL / Table API

Hi Flink Community, I’m writing to confirm whether lambda expressions are supported with User Defined Functions (UDFs) in FlinkSQL and the Table API. My current understanding is that they are not supported. Can anyone verify this, or let me know if there have been any recent changes regarding t

Re: Investigating use of Custom Trigger to smooth CPU usage

timer is >> configured? Also it would be better if you can attach a FlameGraph to show >> the CPU usage when the timer is triggered. >> >> Best, >> Xiangyu >> >> Tucker Harvey via user 于2023年8月1日周二 05:51写道： >>> >>> Hello Flink communit

Investigating use of Custom Trigger to smooth CPU usage

Hello Flink community! My team is trying to optimize CPU usage on a running job, and we're exploring the option of offsetting the trigger time for smoother CPU patterns. Since adjusting the window will compromise job correctness, we plan to pursue a custom trigger implementation. We were curious

Flink 1.15.1 issue we need help on

Hi, we are trying to determine how fix the following exception. This is an issue that is repeatedly happening for us. We have tried looking online for some solutions. One thread suggested setting idleTimeout but this doesn’t seem supported in Flink Source code. https://github.com/netty/netty/