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
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, 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
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,
this is a known issue that is mentioned in
https://issues.apache.org/jira/browse/FLINK-8921 and should be fixed
soon. Currently, we only split by field but for your case we should also
split expressions. As a workaround you could implement your own scalar
UDF that contains the case/when l
