flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Maximilian Michels <...@apache.org>
Subject Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet)
Date Mon, 23 May 2016 14:17:59 GMT
What error do you get when you don't register the Kryo serializer?

On Mon, May 23, 2016 at 11:57 AM, Flavio Pompermaier
<pompermaier@okkam.it> wrote:
> With this last settings I was able to terminate the job the second time I
> retried to run it, without restarting the cluster..
> If I don't register the serializer for DateTime the job doesn't start at all
> (from Flink 1.x you have to register it [1]).
> I can't understand what's wrong :(
>
> [1]
> https://cwiki.apache.org/confluence/display/FLINK/Migration+Guide%3A+0.10.x+to+1.0.x
>
> Best,
> Flavio

Mime
View raw message