Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
From: Stefan Richter <s.richter@data-artisans.com>
Content-Type: multipart/alternative; boundary="Apple-Mail=_CBF0CF59-694A-4D84-95EB-39C47EE42AEF"
Message-Id: <94290672-1350-44F6-A0EE-91F5F29D7E25@data-artisans.com>
Mime-Version: 1.0 (Mac OS X Mail 9.3 \(3124\))
Subject: Re: Guava immutable collection kryo serialization
Date: Thu, 21 Jul 2016 10:36:34 +0200
References: <CAAn8aO_yvFYjz86NngXJ-WsqMcun3kDJtZE3GNLjRKyafnkPUQ@mail.gmail.com>
To: user@flink.apache.org
In-Reply-To: <CAAn8aO_yvFYjz86NngXJ-WsqMcun3kDJtZE3GNLjRKyafnkPUQ@mail.gmail.com>
archived-at: Thu, 21 Jul 2016 08:37:07 -0000


--Apple-Mail=_CBF0CF59-694A-4D84-95EB-39C47EE42AEF
Content-Transfer-Encoding: quoted-printable
Content-Type: text/plain;
	charset=us-ascii

Hi,

to answer this question, it would be helpful if you could provide the =
stacktrace of your exception and the code you use to register the =
serializer.

Best,
Stefan

> Am 21.07.2016 um 05:28 schrieb Shaosu Liu <shu@uber.com>:
>=20
>=20
> Hi,
>=20
> How do I do Guava Immutable collections serialization in Flink?
>=20
> I am getting error=20
>=20
> Caused by: java.io.NotSerializableException: =
de.javakaffee.kryoserializers.guava.ImmutableMapSerializer
>=20
> when I register ImmutableMap to be serialized by the =
ImmutableMapSerializer. I am using the latest version of 0.38.
>=20
> --=20
> Cheers,
> Shaosu


--Apple-Mail=_CBF0CF59-694A-4D84-95EB-39C47EE42AEF
Content-Transfer-Encoding: quoted-printable
Content-Type: text/html;
	charset=us-ascii

<html><head><meta http-equiv=3D"Content-Type" content=3D"text/html =
charset=3Dus-ascii"></head><body style=3D"word-wrap: break-word; =
-webkit-nbsp-mode: space; -webkit-line-break: after-white-space;" =
class=3D"">Hi,<div class=3D""><br class=3D""></div><div class=3D"">to =
answer this question, it would be helpful if you could provide the =
stacktrace of your exception and the code you use to register the =
serializer.</div><div class=3D""><br class=3D""></div><div =
class=3D"">Best,</div><div class=3D"">Stefan</div><div class=3D""><br =
class=3D""><div><blockquote type=3D"cite" class=3D""><div class=3D"">Am =
21.07.2016 um 05:28 schrieb Shaosu Liu &lt;<a href=3D"mailto:shu@uber.com"=
 class=3D"">shu@uber.com</a>&gt;:</div><br =
class=3D"Apple-interchange-newline"><div class=3D""><div dir=3D"ltr" =
class=3D""><br clear=3D"all" class=3D""><div class=3D""><span =
style=3D"font-size:16px" class=3D"">Hi,</span><div =
style=3D"font-size:16px" class=3D""><div class=3D""><br class=3D"">How =
do I do Guava Immutable collections serialization in Flink?</div><div =
class=3D""><br class=3D""></div></div><div style=3D"font-size:16px" =
class=3D"">I am getting error&nbsp;</div><div style=3D"font-size:16px" =
class=3D""><br class=3D""></div><div style=3D"font-size:16px" =
class=3D"">Caused by: java.io.NotSerializableException: =
de.javakaffee.kryoserializers.guava.ImmutableMapSerializer<br =
class=3D""></div><div style=3D"font-size:16px" class=3D""><br =
class=3D""></div><div style=3D"font-size:16px" class=3D"">when I =
register ImmutableMap to be serialized by the ImmutableMapSerializer. I =
am using the latest version of 0.38.</div><div style=3D"font-size:16px" =
class=3D""><br class=3D""></div></div>-- <br class=3D""><div =
class=3D"gmail_signature" data-smartmail=3D"gmail_signature"><div =
dir=3D"ltr" class=3D"">Cheers,<div class=3D"">Shaosu</div></div></div>
</div>
</div></blockquote></div><br class=3D""></div></body></html>=

--Apple-Mail=_CBF0CF59-694A-4D84-95EB-39C47EE42AEF--