You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ra...@apache.org on 2019/09/27 20:53:54 UTC
[samza] branch master updated (6d91400 -> ba1d456)

This is an automated email from the ASF dual-hosted git repository.

rayman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.


    from 6d91400  SAMZA-2328: [Scala cleanup] Convert StreamConfig to Java (part 1: update test coverage and clarify functionality in javadocs) (#1166)
     add ba1d456  SAMZA-2319: [1/2] Simplify Container Allocation logic (#1152)

No new revisions were added by this update.

Summary of changes:
 .../clustermanager/AbstractContainerAllocator.java | 207 +++++++++++++++++++--
 .../samza/clustermanager/ContainerAllocator.java   |  74 --------
 .../clustermanager/ContainerProcessManager.java    |  22 +--
 .../HostAwareContainerAllocator.java               | 177 ------------------
 ...=> MockContainerAllocatorWithHostAffinity.java} |   9 +-
 ...MockContainerAllocatorWithoutHostAffinity.java} |   7 +-
 ...=> TestContainerAllocatorWithHostAffinity.java} | 170 +++++++++++++++--
 ...TestContainerAllocatorWithoutHostAffinity.java} |  70 ++++++-
 .../TestContainerProcessManager.java               |  25 +--
 .../samza/diagnostics/TestDiagnosticsManager.java  |   3 +-
 10 files changed, 441 insertions(+), 323 deletions(-)
 delete mode 100644 samza-core/src/main/java/org/apache/samza/clustermanager/ContainerAllocator.java
 delete mode 100644 samza-core/src/main/java/org/apache/samza/clustermanager/HostAwareContainerAllocator.java
 rename samza-core/src/test/java/org/apache/samza/clustermanager/{MockHostAwareContainerAllocator.java => MockContainerAllocatorWithHostAffinity.java} (87%)
 rename samza-core/src/test/java/org/apache/samza/clustermanager/{MockContainerAllocator.java => MockContainerAllocatorWithoutHostAffinity.java} (88%)
 rename samza-core/src/test/java/org/apache/samza/clustermanager/{TestHostAwareContainerAllocator.java => TestContainerAllocatorWithHostAffinity.java} (72%)
 rename samza-core/src/test/java/org/apache/samza/clustermanager/{TestContainerAllocator.java => TestContainerAllocatorWithoutHostAffinity.java} (72%)