kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bill Bejeck <b...@confluent.io>
Subject Re: ClassCastException when trying to groupBy after suppress
Date Mon, 08 Apr 2019 15:06:14 GMT
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