[ https://issues.apache.org/jira/browse/KAFKA-5771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141935#comment-16141935 ]
Guozhang Wang commented on KAFKA-5771: -------------------------------------- [~radzish] Your patch has been merged by Damian, so you are all set, thanks for the contribution! I have added you to the contributor list so that you can assign tickets to yourself in the future. > org.apache.kafka.streams.state.internals.Segments#segments method returns > incorrect results when segments were added out of order > --------------------------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-5771 > URL: https://issues.apache.org/jira/browse/KAFKA-5771 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 0.11.0.0 > Reporter: Alexander Radzishevsky > Assignee: Alexander Radzishevsky > Fix For: 0.11.0.1, 1.0.0 > > > following unit test in org.apache.kafka.streams.state.internals.SegmentsTest > will fail > {code:title=org.apache.kafka.streams.state.internals.SegmentsTest.java|borderStyle=solid} > @Test > public void shouldGetSegmentsWithinTimeRangeOutOfOrder() throws Exception > { > segments.getOrCreateSegment(4, context); > segments.getOrCreateSegment(2, context); > segments.getOrCreateSegment(0, context); > segments.getOrCreateSegment(1, context); > segments.getOrCreateSegment(3, context); > final List<Segment> segments = this.segments.segments(0, 2 * 60 * > 1000); > assertEquals(3, segments.size()); > assertEquals(0, segments.get(0).id); > assertEquals(1, segments.get(1).id); > assertEquals(2, segments.get(2).id); > } > {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)