Thank a lot, best wishes
发自我的小米手机在 JING ZHANG ,2021年6月22日 下午5:59写道:Hi houyin,> I just thought flink engine will help me to do the type implicit conversion.I agree with you, it is a reasonable expectation. There is a FLIP about implicit type coercion [1]. Hope it helps.[1] https://cwiki.apache.or
Hi houyin,
> I just thought flink engine will help me to do the type implicit
conversion.
I agree with you, it is a reasonable expectation. There is a FLIP about
implicit type coercion [1]. Hope it helps.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-154%3A+SQL+Implicit+Type+Coercion
Hi JING ZHANG,
Thank for your reply. I got the points why the exception cause which is I use
the b as varchar to compare when '' and '1' instead of intType.
I just thought flink engine will help me to do the type implicit conversion.
So for now, I'd better fix it in a right way such as select *
nard Xu
抄送: 纳兰清风 ; User-Flink
主题: Re: Flink sql case when problem
Hi houying,
The root cause of `CodeGenException` is comparing Integer with Varchar (b is
VARCHAR, '' and '0' are VARCHAR).
The Problem could be solved by updating type of b from INTEGER to VARCHAR.
Note,
Hi houying,
The root cause of `CodeGenException` is comparing Integer with Varchar (b
is VARCHAR, '' and '0' are VARCHAR).
The Problem could be solved by updating type of b from INTEGER to VARCHAR.
Note, comparing INTEGER with VARCHAR may introduce other unexpected
results. For example in your abov
Hi Leonard Xu,
The version is 1.13. Is it a bug? I noticed that the type of column `b` is
integer, but I use it as varchar.
What the expected action should it be ?
At 2021-06-17 20:11:24, "Leonard Xu" wrote:
Hi, houying
It looks like a bug when code generate the operator code,
Hi, houying
It looks like a bug when code generate the operator code, which Flink version
are you using?
Could you help create an JIRA ticket?
Best,
Leonard
> 在 2021年6月17日,19:48,纳兰清风 写道:
>
> Hello,
>
> When I am using case when statement in flink sql, I got an error as
> follow:
>
>
Hello,
When I am using case when statement in flink sql, I got an error as follow:
org.apache.flink.table.planner.codegen.CodeGenException: Unable to find common
type of GeneratedExpression(field$3,isNull$3,,INT,None) and
ArrayBuffer(GeneratedExpression(((org.apache.flink.table.data.binar