[ https://issues.apache.org/jira/browse/APEXMALHAR-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15586277#comment-15586277 ]
ASF GitHub Bot commented on APEXMALHAR-2299: -------------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/apex-malhar/pull/454 > TimeBasedDedupOperator throws exception during time bucket assignment in > certain edge cases > ------------------------------------------------------------------------------------------- > > Key: APEXMALHAR-2299 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2299 > Project: Apache Apex Malhar > Issue Type: Bug > Affects Versions: 3.5.0 > Reporter: Francis Fernandes > Assignee: Francis Fernandes > Fix For: 3.6.0 > > Original Estimate: 96h > Remaining Estimate: 96h > > The following exception is thrown under certain edge cases: > {noformat} > Stopped running due to an exception. java.lang.IllegalArgumentException: new > time bucket should have a value greater than the old time bucket > at > com.google.common.base.Preconditions.checkArgument(Preconditions.java:88) > at > org.apache.apex.malhar.lib.state.managed.ManagedTimeUnifiedStateImpl.handleBucketConflict(ManagedTimeUnifiedStateImpl.java:126) > at > org.apache.apex.malhar.lib.state.managed.AbstractManagedStateImpl.prepareBucket(AbstractManagedStateImpl.java:265) > at > org.apache.apex.malhar.lib.state.managed.AbstractManagedStateImpl.putInBucket(AbstractManagedStateImpl.java:276) > at > org.apache.apex.malhar.lib.state.managed.ManagedTimeUnifiedStateImpl.put(ManagedTimeUnifiedStateImpl.java:71) > at > org.apache.apex.malhar.lib.dedup.TimeBasedDedupOperator.putManagedState(TimeBasedDedupOperator.java:191) > {noformat} -- This message was sent by Atlassian JIRA (v6.3.4#6332)