Skip to content
This repository has been archived by the owner on Jun 7, 2024. It is now read-only.

Commit

Permalink
ARUHA-1624: fixed out of memory problem;
Browse files Browse the repository at this point in the history
  • Loading branch information
v-stepanov committed Apr 23, 2018
1 parent 431b282 commit a919eaf
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ long getBytesInMemory() {
}

private List<ConsumedEvent> extract(final int count) {
final List<ConsumedEvent> result = new ArrayList<>(count);
final List<ConsumedEvent> result = new ArrayList<>();
for (int i = 0; i < count && !nakadiEvents.isEmpty(); ++i) {
final ConsumedEvent event = nakadiEvents.remove(0);
bytesInMemory -= event.getEvent().length;
Expand Down

0 comments on commit a919eaf

Please sign in to comment.