[KAFKA-5771] org.apache.kafka.streams.state.internals.Segments#segments method returns incorrect results when segments were added out of order

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.11.0.0
• Fix Version/s: 0.11.0.1, 1.0.0
• Component/s: streams
• Assignee: Alexander Radzishevsky
• Reporter: Alexander Radzishevsky
• Created: 23/Aug/17 14:03
• Updated: 25/Aug/17 17:39
• Resolved: 25/Aug/17 12:59

Description

following unit test in org.apache.kafka.streams.state.internals.SegmentsTest will fail

org.apache.kafka.streams.state.internals.SegmentsTest.java

    @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);
    }

Issue Links

• links to: GitHub Pull Request #3737