Hello,
Looks like there is a bug with Flink 1.16's IF operator. If I use UPPER or
TRIM functions(there might be more such functions), I am getting the
exception. These functions used to work fine with Flink 1.13.
select
if(
address_id = 'a',
'default',
upper(address_id)
) as
Hi Hang and community,
There is a correction in my earlier email. The issue comes when I use the
UPPER or TRIM function with IF.
Looks like there is a bug with Flink 1.16's IF operator. If I use UPPER or
TRIM functions(there might be more such functions), I am getting the
exception. These
Hi, neha,
I think the error occurred because of the deserialization. Is there some
example data and runnable SQLs to reproduce the problem?
Best,
Hang
neha goyal 于2023年5月2日周二 16:33写道：
> Hello,
>
> I am using Flink 1.16.1 and observing a different behavior from Flink
> 1.13.6.
>
> SELECT
Hello,
I am using Flink 1.16.1 and observing a different behavior from Flink
1.13.6.
SELECT if(some_string_field is null, 'default', 'some_string_field') from
my_stream
This SQL flink job in the streaming environment is erroring out during
runtime with the exception mentioned below. There are
