m-trieu commented on code in PR #31902:
URL: https://github.com/apache/beam/pull/31902#discussion_r1792467507
##########
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/GetWorkBudgetDistributors.java:
##########
@@ -24,6 +24,10 @@
public final class GetWorkBudgetDistributors {
public static GetWorkBudgetDistributor distributeEvenly(
Supplier<GetWorkBudget> activeWorkBudgetSupplier) {
- return new EvenGetWorkBudgetDistributor(activeWorkBudgetSupplier);
+ return new EvenGetWorkBudgetDistributor(activeWorkBudgetSupplier, true);
Review Comment:
it eventually will not be always false
the future version is that there will be a background thread handling the
budget distribution and we can modify the budgeting algorithm for that thread
to use.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
