Hi,
We hit a situation where the code generation on Flink grows beyond 64KB and
fails. Spark SQL has a similar issue and it automatically disables
code-generation in such a case. Any way we can control that here? Following
is the error stack:
org.apache.flink.api.common.InvalidProgramException: T
Thanks Hequn for pointing out a work around for that, will try that out for
now.
And Timo, I am using 1.3.3. We are in the middle of upgrading Flink, so will
try on 1.5 once that happens and report back. Thanks!
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
I am getting an error when using the Table API with ScalarFunction. This is
previously reported here (https://issues.apache.org/jira/browse/FLINK-7490)
as loading a wrong class loader and is reported as fixed. But the issue
persists even after using the latest code from 1.3 branch.
>From some of
Thanks for the response, the issue does look similar to FLINK-9220.
The code is part of our application, so I have to come up with an example.
But following are the steps that will likely reproduce the issue.
1. Define UDF in module, say in com.udf
2. Create a topology using the above UDF in anot
