Thanks to Fabian and Timo, I watched the scalar udf and find it is very quick
to implements a case when udf for the specify logic to meet my necessary
Cheers
Minglei
> 在 2018年6月19日，下午10:52，Fabian Hueske 写道：
>
> I see, then this case wasn't covered by the fix that we added for Flink
> 1.5.0.
I see, then this case wasn't covered by the fix that we added for Flink
1.5.0.
I guess the problem is that the code is needed to evaluate a single field.
Implementing a scalar user-function is not very difficult [1].
However, you need to register it in the TableEnvironment before you can use
it in
Hi, Fabian, Absolutely, Flink 1.5.0 I am using for this. A big CASE WHEN
statement. Is it hard to implement ? I am a new to flink table api & sql.
Best Minglei.
> 在 2018年6月19日，下午10:36，Fabian Hueske 写道：
>
> Hi,
>
> Which version are you using? We fixed a similar issue for Flink 1.5.0.
> If you
Hi,
Which version are you using? We fixed a similar issue for Flink 1.5.0.
If you can't upgrade yet, you can also implement a user-defined function
that evaluates the big CASE WHEN statement.
Best, Fabian
2018-06-19 16:27 GMT+02:00 zhangminglei <18717838...@163.com>:
> Hi, friends.
>
> When I e
Hi, friends.
When I execute a long sql and get the follow error, how can I have a quick fix ?
org.apache.flink.api.common.InvalidProgramException: Table program cannot be
compiled. This is a bug. Please file an issue.
at
org.apache.flink.table.codegen.Compiler$class.compile(Compiler.sca
