kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vvcep...@apache.org
Subject [kafka] branch trunk updated (fad8db6 -> d62f6eb)
Date Thu, 14 May 2020 13:33:09 GMT
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


Mime
View raw message