[ 
https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15536587#comment-15536587
 ] 

Siyuan Hua commented on APEXMALHAR-2276:
----------------------------------------

The problem is in the DefaultBucket implementation that the in same time bucket 
the key can only be written once. As we use monotonically advancing window id 
as time bucket before, there is no problem. But my understanding is 
ManagedTimeUnifiedStateImpl should handle this in a general way?

> ManagedTimeUnifiedStateImpl doesn't support time events properly
> ----------------------------------------------------------------
>
>                 Key: APEXMALHAR-2276
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2276
>             Project: Apache Apex Malhar
>          Issue Type: Sub-task
>            Reporter: Siyuan Hua
>
> For example:
> ManagedTimeUnifiedStateImpl mtus;
> mtus.put(10000, key1, val1)
> mtus.put(10000, key1, val2)
> mtus.get(10000, key1).equals(val2) will return false



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to