Skip to content

Commit

Permalink
fix(titus): adjust page size for titus queries (#3854)
Browse files Browse the repository at this point in the history
based on feedback from titus team, adjust page size for titus job/tasks
requests to 1k
  • Loading branch information
marchello2000 committed Jul 8, 2019
1 parent d630962 commit f10beae
Showing 1 changed file with 2 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -416,8 +416,7 @@ public Map<String, List<String>> getTaskIdsForJobIds() {
.addFields("id")
.addFields("jobId");

List<com.netflix.titus.grpc.protogen.Task> grpcTasks =
getTasksWithFilter(taskQueryBuilder, 10000);
List<com.netflix.titus.grpc.protogen.Task> grpcTasks = getTasksWithFilter(taskQueryBuilder);
return grpcTasks.stream()
.collect(
Collectors.groupingBy(
Expand Down Expand Up @@ -491,12 +490,8 @@ private List<com.netflix.titus.grpc.protogen.Job> getJobsWithFilter(

private List<com.netflix.titus.grpc.protogen.Task> getTasksWithFilter(
TaskQuery.Builder taskQueryBuilder) {
return getTasksWithFilter(
taskQueryBuilder, titusRegion.getFeatureFlags().contains("largePages") ? 2000 : 1000);
}

private List<com.netflix.titus.grpc.protogen.Task> getTasksWithFilter(
TaskQuery.Builder taskQueryBuilder, Integer pageSize) {
final int pageSize = 1000;
List<com.netflix.titus.grpc.protogen.Task> grpcTasks = new ArrayList<>();

TaskQueryResult taskResults;
Expand Down

0 comments on commit f10beae

Please sign in to comment.