254a98db0966914bc07094e168667e1a851affcf - storm

commit	254a98db0966914bc07094e168667e1a851affcf	[log] [tgz]
author	Rui Li <rui.li@verizonmedia.com>	Wed Dec 23 15:18:28 2020 -0600
committer	GitHub <noreply@github.com>	Wed Dec 23 15:18:28 2020 -0600
tree	36b993ed1d1b86e68d43dd0d0d3ae38f01aeae04
parent	ab6b6f69a10bf57c1b46a6519d57ca423d99558c [diff]

[STORM-3650] attempt to evenly distribute ackers to workers with optional acker-per-worker config (#3346)

conf/defaults.yaml[diff]
storm-client/src/jvm/org/apache/storm/Config.java[diff]
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java[diff]
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java[diff]
storm-server/src/main/java/org/apache/storm/scheduler/ISchedulingState.java[diff]
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java[diff]
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/BaseResourceAwareStrategy.java[diff]
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/IStrategy.java[diff]
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/SchedulingSearcherState.java[diff]
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/ExecSorterByConnectionCount.java[diff]
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/ExecSorterByProximity.java[diff]
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java[diff]
storm-server/src/test/java/org/apache/storm/daemon/nimbus/NimbusTest.java[diff]
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestBackwardCompatibility.java[diff]
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestConstraintSolverStrategy.java[diff]
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestDefaultResourceAwareStrategy.java[diff]
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestGenericResourceAwareStrategy.java[diff]
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java[diff]

18 files changed