{"action":"opened","issue":{"url":"https://api.github.com/repos/pravega/pravega/issues/2298","repository_url":"https://api.github.com/repos/pravega/pravega","labels_url":"https://api.github.com/repos/pravega/pravega/issues/2298/labels{/name}","comments_url":"https://api.github.com/repos/pravega/pravega/issues/2298/comments","events_url":"https://api.github.com/repos/pravega/pravega/issues/2298/events","html_url":"https://github.com/pravega/pravega/issues/2298","id":294981635,"number":2298,"title":"Readers do not correctly rebalance.","user":{"login":"tkaitchuck","id":4756752,"avatar_url":"https://avatars1.githubusercontent.com/u/4756752?v=4","gravatar_id":"","url":"https://api.github.com/users/tkaitchuck","html_url":"https://github.com/tkaitchuck","followers_url":"https://api.github.com/users/tkaitchuck/followers","following_url":"https://api.github.com/users/tkaitchuck/following{/other_user}","gists_url":"https://api.github.com/users/tkaitchuck/gists{/gist_id}","starred_url":"https://api.github.com/users/tkaitchuck/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/tkaitchuck/subscriptions","organizations_url":"https://api.github.com/users/tkaitchuck/orgs","repos_url":"https://api.github.com/users/tkaitchuck/repos","events_url":"https://api.github.com/users/tkaitchuck/events{/privacy}","received_events_url":"https://api.github.com/users/tkaitchuck/received_events","type":"User","site_admin":false},"labels":[{"id":499236073,"url":"https://api.github.com/repos/pravega/pravega/labels/area/client","name":"area/client","color":"c2e0c6","default":false}],"state":"open","locked":false,"assignee":{"login":"tkaitchuck","id":4756752,"avatar_url":"https://avatars1.githubusercontent.com/u/4756752?v=4","gravatar_id":"","url":"https://api.github.com/users/tkaitchuck","html_url":"https://github.com/tkaitchuck","followers_url":"https://api.github.com/users/tkaitchuck/followers","following_url":"https://api.github.com/users/tkaitchuck/following{/other_user}","gists_url":"https://api.github.com/users/tkaitchuck/gists{/gist_id}","starred_url":"https://api.github.com/users/tkaitchuck/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/tkaitchuck/subscriptions","organizations_url":"https://api.github.com/users/tkaitchuck/orgs","repos_url":"https://api.github.com/users/tkaitchuck/repos","events_url":"https://api.github.com/users/tkaitchuck/events{/privacy}","received_events_url":"https://api.github.com/users/tkaitchuck/received_events","type":"User","site_admin":false},"assignees":[{"login":"tkaitchuck","id":4756752,"avatar_url":"https://avatars1.githubusercontent.com/u/4756752?v=4","gravatar_id":"","url":"https://api.github.com/users/tkaitchuck","html_url":"https://github.com/tkaitchuck","followers_url":"https://api.github.com/users/tkaitchuck/followers","following_url":"https://api.github.com/users/tkaitchuck/following{/other_user}","gists_url":"https://api.github.com/users/tkaitchuck/gists{/gist_id}","starred_url":"https://api.github.com/users/tkaitchuck/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/tkaitchuck/subscriptions","organizations_url":"https://api.github.com/users/tkaitchuck/orgs","repos_url":"https://api.github.com/users/tkaitchuck/repos","events_url":"https://api.github.com/users/tkaitchuck/events{/privacy}","received_events_url":"https://api.github.com/users/tkaitchuck/received_events","type":"User","site_admin":false}],"milestone":null,"comments":0,"created_at":"2018-02-07T02:09:12Z","updated_at":"2018-02-07T02:09:12Z","closed_at":null,"author_association":"COLLABORATOR","body":"**Problem description**\r\nIf there are multiple readers and they get unbalanced, such that more segments are assigned to one than the others, they do not properly rebalance segments among themselves. \r\n```\r\nERROR [2018-02-05 22:07:01.593] [Source: AnnotatedDataReader -> DecodeMapper -> BacklogMonitorMapper -> Sink: Publish-Decoded-Data (3/7)] i.p.c.s.impl.EventStreamReaderImpl: segmentNumbers=[23, 0, 21, 22]\r\nERROR [2018-02-05 22:07:01.608] [Source: AnnotatedDataReader -> DecodeMapper -> BacklogMonitorMapper -> Sink: Publish-Decoded-Data (6/7)] i.p.c.s.impl.EventStreamReaderImpl: segmentNumbers=[19, 20, 17, 18, 15, 16, 13, 14]\r\nERROR [2018-02-05 22:07:01.610] [Source: AnnotatedDataReader -> DecodeMapper -> BacklogMonitorMapper -> Sink: Publish-Decoded-Data (2/7)] i.p.c.s.impl.EventStreamReaderImpl: segmentNumbers=[]\r\nERROR [2018-02-05 22:07:01.610] [Source: AnnotatedDataReader -> DecodeMapper -> BacklogMonitorMapper -> Sink: Publish-Decoded-Data (1/7)] i.p.c.s.impl.EventStreamReaderImpl: segmentNumbers=[]\r\nERROR [2018-02-05 22:07:01.610] [Source: AnnotatedDataReader -> DecodeMapper -> BacklogMonitorMapper -> Sink: Publish-Decoded-Data (7/7)] i.p.c.s.impl.EventStreamReaderImpl: segmentNumbers=[]\r\nERROR [2018-02-05 22:07:01.611] [Source: AnnotatedDataReader -> DecodeMapper -> BacklogMonitorMapper -> Sink: Publish-Decoded-Data (4/7)] i.p.c.s.impl.EventStreamReaderImpl: segmentNumbers=[]\r\nERROR [2018-02-05 22:07:01.617] [Source: AnnotatedDataReader -> DecodeMapper -> BacklogMonitorMapper -> Sink: Publish-Decoded-Data (5/7)] i.p.c.s.impl.EventStreamReaderImpl: segmentNumbers=[3, 4, 1, 2, 7, 8, 5, 6, 11, 12, 9, 10]\r\n```\r\n\r\n\r\n**Problem location**\r\nReaderGroupStateManager\r\n\r\n**Suggestions for an improvement**\r\nAdd test coverage"}}
{"actor":{"display_login":"tkaitchuck"}}