flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Error "Could not load deserializer from the configuration"
Date Tue, 11 Nov 2014 06:48:30 GMT
Hi,
which version of Flink are you using?

Cheers,
Aljoscha

On Tue, Nov 11, 2014 at 12:09 AM, Stefan Bunk
<stefan.bunk@googlemail.com> wrote:
> Hi Flinkers,
>
> I get the following error right after starting/deploying my program on the
> cluster:
> java.lang.RuntimeException: The initialization of the DataSource's outputs
> caused an error: Could not load deserializer from the configuration.
> ...
> Caused by: java.io.InvalidClassException:
> org.apache.flink.api.scala.typeutils.CaseClassSerializer; local class
> incompatible: stream classdesc serialVersionUID = 7795994801161867172, local
> class serialVersionUID = 1572449491425739294
>
> I see this is an serialization issue, but I do not get why.
> My workflow:
> I call `mvn package` to build a jar with all dependencies, then execute my
> program with the remote environment, referencing my newly created *.jar.
>
> What exactly does that tell me, and where do I have to look?
>
> Cheers
> Stefan

Mime
View raw message