Re: ClassCastException in KStreams job for SessionWindow aggregation

2018-05-02 Thread Conrad Crampton
Thanks Damian for taking the time to point out my stupidity - that was it :-) Case of Occams Razor!! Thanks again On Wed, 2 May 2018 at 16:56 Conrad Crampton wrote: > Looks like I may be victim of that copy and paste gremlin!! > Without checking I think you might be onto something - I'll check i

Re: ClassCastException in KStreams job for SessionWindow aggregation

2018-05-02 Thread Conrad Crampton
Looks like I may be victim of that copy and paste gremlin!! Without checking I think you might be onto something - I'll check it out later and repost back. On one hand I really hope it's this, on the other I can't believe I've been so stupid! Thanks On Wed, 2 May 2018 at 16:30 Damian Guy wrote:

Re: ClassCastException in KStreams job for SessionWindow aggregation

2018-05-02 Thread Damian Guy
Hi, I think it **might** be related to this: final Serializer httpSessionSerializer = new JsonPOJOSerializer<>(); serdeProps.put("JsonPOJOClass", Http.class); httpSessionSerializer.configure(serdeProps, false); final Deserializer httpSessionDeserializer = new JsonPOJODe

ClassCastException in KStreams job for SessionWindow aggregation

2018-05-02 Thread Conrad Crampton
I'm trying to window over http logs and create an HttpSession i.e. a list of http requests (and some other properties). However when in my aggregate Merger part (I think) I'm getting a classcastexception I think in when my sessions are being merged and cannot for the life of me work out why. The ex