Re: Need help using AggregateFunction instead of FoldFunction

Posted by devinbost on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Need-help-using-AggregateFunction-instead-of-FoldFunction-tp31421p31429.html

It turns out that the exception that I was getting is actually related to
Pulsar since I'm using the Pulsar Flink connector. I found the exact issue
reported here: https://github.com/apache/pulsar/issues/4721


devinbost wrote

> I was able to make more progress (based on the documentation you
> provided),
> but now I'm getting this exception:
>
> org.apache.pulsar.client.impl.DefaultBatcherBuilder@3b5fad2d is not
> serializable. The object probably contains or references non serializable
> fields.
> org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:151)
> org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:126)
> org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:126)
> org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:71)

--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/