gt;
> > is there any mathematical rules to create specific no.of partitions for
> > Topic.???
> >
> >
> > please help me
> >
> > Sent from Outlook<http://aka.ms/weboutlook>
> >
> > From: Jose Lopez
&
Hi all,
Given that gradePeriodMs is "the time to admit late-arriving events after
the end of the window", I'd expect it is taken into account in
windowsFor(timestamp). E.g.:
sizeMs = 5
gracePeriodMs = 2
advanceMs = 3
timestamp = 6
| window | windowStart | windowEnd | windowsEnd + gracePeriod |
|
Bill,
Fixed, thank you!
Regards,
Jose
On Tue, 9 Apr 2019 at 15:55, Bill Bejeck wrote:
> Jose,
>
> I can see you listed as a contributor, can you try logging out and logging
> back in?
>
> Thanks
> Bill
>
> On Tue, Apr 9, 2019 at 7:27 AM Jose Lopez
> wrote:
Bill,
Could you please double check? It seems I cannot assign the issue to me yet.
Regards,
Jose
On Mon, 8 Apr 2019 at 23:24, Bill Bejeck wrote:
> Jose,
>
> You're all set. I look forward to your PR.
>
> Thanks,
> Bill
>
> On Mon, Apr 8, 2019 at 4:59 PM Jo
ns, assign the Jira
> ticket to yourself and submit a PR.
>
> If you don't have an Apache Jira account, sign up for one and list your
> jira userid here and I'll get you added as a contributor.
>
> Thanks,
> Bill
>
> On Mon, Apr 8, 2019 at 11:52 AM Jose Lopez
>
a
> https://issues.apache.org/jira/browse/KAFKA-8199 for tracking the issue.
>
> -Bill
>
> On Mon, Apr 8, 2019 at 5:49 AM Jose Lopez
> wrote:
>
> > Hi all,
> >
> > My topology is:
> >
> > stream -> groupByKey -> windowedBy -> count -> suppres
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
can
