flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Error "Could not load deserializer from the configuration"
Date Tue, 11 Nov 2014 13:17:46 GMT
I think this is because there was no static serialVersionUID added. In that
case, Java computes one by itself as a checksum.

It makes sense to add those to all serializable classes.

On Tue, Nov 11, 2014 at 2:02 PM, Stefan Bunk <stefan.bunk@googlemail.com>
wrote:

> Hi,
>
> this turned out to be a version conflict. The cluster was running on the
> latest 0.7 snapshot, and my code ran on the 0.7 release. Even when I used
> the 0.7 snapshot in my code again, it did not work.
> We updated the cluster to the release now as well, and it works again.
>
> For the future: do they need to be at the exact same version (i.e. commit)
> or only when there are serious changes in-between?
>
> Thanks for pointing me in the right direction.
>
>
> On Tue, Nov 11, 2014 at 11:17 AM, Stefan Bunk <stefan.bunk@googlemail.com>
> wrote:
>
>> 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