kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jose Lopez <joseariaslo...@gmail.com>
Subject Re: ClassCastException when trying to groupBy after suppress
Date Mon, 08 Apr 2019 15:52:21 GMT
Thank you for the prompt response, Bill.

Do you have an estimated date as to when this could be fixed? Are you open
to new developers / collaborators?

Regards,
Jose

On Mon, 8 Apr 2019 at 17:06, Bill Bejeck <bill@confluent.io> wrote:

> Jose,
>
> Thanks for reporting this we have created this Jira
> https://issues.apache.org/jira/browse/KAFKA-8199 for tracking the issue.
>
> -Bill
>
> On Mon, Apr 8, 2019 at 5:49 AM Jose Lopez <joseariaslopez@gmail.com>
> wrote:
>
> > Hi all,
> >
> > My topology is:
> >
> > stream -> groupByKey -> windowedBy -> count -> suppress -> groupBy
->
> > aggregate -> toStream
> >
> > When I *groupBy* after *suppress*, the following exception is thrown:
> >
> > java.lang.ClassCastException:
> >
> org.apache.kafka.streams.kstream.internals.KTableImpl$$Lambda$15/1208825205
> > cannot be cast to
> > org.apache.kafka.streams.kstream.internals.KTableProcessorSupplier
> >
> > It happens because suppress returns a KtableImpl with a
> > KTableSuppressProcessor. Then groupBy, when
> > executes enableSendingOldValues(), it casts it to
> KTableProcessorSupplier,
> > and therefore the ClassCastException.
> >
> > Is this a bug? Am I missing something?
> >
> > Thank you in advance for your help.
> >
> > Regards,
> > Jose
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message