Re: Streaming User-defined Aggregate Function gives exception when using Table API jars

2017-11-15 Thread Colin Williams
Thank you Fabian for fixing that. The highlight of my day today. On Nov 15, 2017 1:01 AM, "Fabian Hueske" wrote: > Hi Colin, > > thanks for reporting the bug. I had a look at it and it seems that the > wrong classloader is used when compiling the code (both for the batch as > well as the stream

Re: Streaming User-defined Aggregate Function gives exception when using Table API jars

2017-11-15 Thread Fabian Hueske
Hi Colin, thanks for reporting the bug. I had a look at it and it seems that the wrong classloader is used when compiling the code (both for the batch as well as the streaming queries). I have a fix that I need to verify. It's not necessary to open a new JIRA for that. We can cover all cases unde

Streaming User-defined Aggregate Function gives exception when using Table API jars

2017-11-14 Thread Colin Williams
>From the documentation there is a note which instructs not to include the flink-table dependency into the project. However when I put the flink-table dependency on the cluster the User-defined Aggregate Function gives an Exception. When I do include the flink-table into the dependencies, the proj