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" <devin.b...@gmail.com>
To: user@flink.apache.org
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/
