You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2020/05/14 13:33:09 UTC
[kafka] branch trunk updated (fad8db6 -> d62f6eb)
This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from fad8db6 MINOR: add option to rebuild source for system tests (#6656)
add d62f6eb KAFKA-6145: KIP-441: Improve assignment balance (#8588)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/common/utils/Utils.java | 17 ++
.../org/apache/kafka/common/utils/UtilsTest.java | 84 ++++++
.../internals/StreamsPartitionAssignor.java | 2 +-
.../assignment/AssignorConfiguration.java | 10 +
.../internals/assignment/BalancedAssignor.java | 30 --
.../internals/assignment/ClientState.java | 245 +++++++--------
...kLoadQueue.java => ConstrainedPrioritySet.java} | 79 ++---
.../assignment/DefaultBalancedAssignor.java | 86 ------
.../assignment/FallbackPriorTaskAssignor.java | 4 +-
.../assignment/HighAvailabilityTaskAssignor.java | 230 ++++++++------
.../internals/assignment/RankedClient.java | 143 ---------
.../internals/assignment/StickyTaskAssignor.java | 4 +-
.../internals/assignment/TaskAssignor.java | 2 +-
.../internals/assignment/TaskMovement.java | 139 +++++----
.../internals/assignment/AssignmentTestUtils.java | 330 ++++++++++++++++++++-
.../internals/assignment/ClientStateTest.java | 100 +++++++
.../assignment/ConstrainedPrioritySetTest.java | 111 +++++++
.../assignment/DefaultBalancedAssignorTest.java | 295 ------------------
.../HighAvailabilityTaskAssignorTest.java | 309 ++++++++++++-------
.../internals/assignment/RankedClientTest.java | 196 ------------
.../assignment/TaskAssignorConvergenceTest.java | 164 +++++-----
.../internals/assignment/TaskMovementTest.java | 304 +++++++------------
.../ValidClientsByTaskLoadQueueTest.java | 126 --------
23 files changed, 1427 insertions(+), 1583 deletions(-)
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/BalancedAssignor.java
rename streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/{ValidClientsByTaskLoadQueue.java => ConstrainedPrioritySet.java} (50%)
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultBalancedAssignor.java
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RankedClient.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySetTest.java
delete mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/DefaultBalancedAssignorTest.java
delete mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/RankedClientTest.java
delete mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ValidClientsByTaskLoadQueueTest.java