Re: Need help using AggregateFunction instead of FoldFunction

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

I hit the same problem, as far as I can tell it should be fixed in Pulsar 2.4.2. The release of this has already passed voting so I hope it should be available in a day or two.

https://github.com/apache/pulsar/pull/5068

------ Original Message ------

From: "devinbost" <[hidden email]>

To: [hidden email]

Sent: 05/12/2019 04:35:05

Subject: Re: Need help using AggregateFunction instead of FoldFunction

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/