flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stefan Bunk <stefan.b...@googlemail.com>
Subject Re: Error "Could not load deserializer from the configuration"
Date Tue, 11 Nov 2014 10:17:14 GMT
Hi,

I am using Flink 0.7 both in my program and on the cluster.

Cheers
Stefan

On Tue, Nov 11, 2014 at 7:48 AM, Aljoscha Krettek <aljoscha@apache.org>
wrote:

> 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