flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chris Miller" <chris...@gmail.com>
Subject Re: Need help using AggregateFunction instead of FoldFunction
Date Thu, 05 Dec 2019 09:43:32 GMT
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.


------ Original Message ------
From: "devinbost" <devin.bost@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/
View raw message