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/
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
larFunction {
>
>
>
>
>transient Function f;
>
>
>
>
>@Override
>
>public void open(FunctionContext context) throws Exception {
>
>f = str -> str + ":test";
>
>}
>
>
>
>
>public String eval
