beam-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dan Halperin <>
Subject Re: weird serialization issue on beam 2.0.0rc2
Date Thu, 11 May 2017 23:42:00 GMT
Hi Anthony,

I'm a little confused by your code snippet:

    input.apply(ParDo.of(new NonGenericOutput<>())).apply("passing",

is serializing a PCollectionView object. Those are not necessarily
serializable and it's not clear that it makes sense to do this at all.

Can you say more about what you're trying to do?


On Thu, May 11, 2017 at 4:21 PM, Antony Mayi <> wrote:

> I tried the 2.0.0rc2 and I started facing weird serialization issue that's
> not been happening on 0.6.0. I am able to reproduce it using the attached
> unit test - see first serialization attempt which is passing ok and second
> one slightly different (transform output type is generic) that's failing
> just on 2.0.0
> Can anyone find a way around it? In my real case I depend on generics
> output types.
> thanks,
> antony.

View raw message