You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Asutosh Pandya (JIRA)" <ji...@apache.org> on 2018/02/27 00:51:00 UTC
[jira] [Comment Edited] (KAFKA-6486) TimeWindows causes unordered
calls to windowed aggregation functions
[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16377860#comment-16377860 ]
Asutosh Pandya edited comment on KAFKA-6486 at 2/27/18 12:50 AM:
-----------------------------------------------------------------
[~guozhang]
Added patch with above mentioned change.
I already have one Pull Request to merge, hence attaching patch.
Best Regards,
Asutosh
was (Author: asutosh_pandya):
Added patch with above mentioned change.
I already have one Pull Request to merge, hence attaching patch.
Best Regards,
Asutosh
> TimeWindows causes unordered calls to windowed aggregation functions
> --------------------------------------------------------------------
>
> Key: KAFKA-6486
> URL: https://issues.apache.org/jira/browse/KAFKA-6486
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 1.0.0
> Reporter: Valentino Proietti
> Priority: Minor
> Attachments: KAFKA-6486.patch
>
>
> This is not a real bug but it causes some weird behaviour, at least in my opinion.
> The TimeWindows has a method called windowsFor() that uses and returns an HashMap:
> @Override
> *public* Map<Long, TimeWindow> windowsFor(*final* *long* timestamp) {
> *long* windowStart = (Math._max_(0, timestamp - sizeMs + advanceMs) / advanceMs) * advanceMs;
> *final* Map<Long, TimeWindow> windows = *new* HashMap<>();
> ....
> the HashMap does not preserve the order of insertion and this ends up later in calls to any streams windowed aggregation functions that are not ordered by window time as I would expect.
> A simple solution is to replace the HashMap with a LinkedHashMap and that's what I did.
> Anyway replacing it directly in your code can save hours of debugging to understand what's happening.
> Thank you
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)