Skip to content

Commit

Permalink
addendum for branch-2
Browse files Browse the repository at this point in the history
  • Loading branch information
ndimiduk committed Jul 22, 2024
1 parent 305b08e commit b4bd02c
Showing 1 changed file with 4 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,6 @@
import java.util.Collections;
import java.util.EnumSet;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
Expand Down Expand Up @@ -3153,16 +3152,15 @@ protected Void rpcCall() throws Exception {

@Override
public QuotaRetriever getQuotaRetriever(final QuotaFilter filter) throws IOException {
return QuotaRetriever.open(conf, filter);
return new QuotaRetriever(connection, filter);
}

@Override
public List<QuotaSettings> getQuota(QuotaFilter filter) throws IOException {
List<QuotaSettings> quotas = new ArrayList<>();
try (QuotaRetriever retriever = QuotaRetriever.open(conf, filter)) {
Iterator<QuotaSettings> iterator = retriever.iterator();
while (iterator.hasNext()) {
quotas.add(iterator.next());
try (QuotaRetriever retriever = new QuotaRetriever(connection, filter)) {
for (QuotaSettings quotaSettings : retriever) {
quotas.add(quotaSettings);
}
}
return quotas;
Expand Down

0 comments on commit b4bd02c

Please sign in to comment.