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 92f53c7 SAMZA-2275: Azure Blob System Producer: fixes for high level
jobs (#1258)
add 841c9a7 SAMZA-2373: [SEP-22] Container Placement Service (core
functionality) for container move and restart (#1219)
No new revisions were added by this update.
Summary of changes:
.../samza/clustermanager/ContainerAllocator.java | 70 ++-
.../samza/clustermanager/ContainerManager.java | 285 ++++++++++-
.../clustermanager/ContainerProcessManager.java | 3 +-
.../placements/ContainerPlacementMetadata.java | 123 +++++
.../clustermanager/MockClusterResourceManager.java | 5 +-
.../TestContainerAllocatorWithHostAffinity.java | 16 +-
.../TestContainerAllocatorWithoutHostAffinity.java | 6 +-
.../TestContainerPlacementActions.java | 533 +++++++++++++++++++++
.../TestContainerProcessManager.java | 34 +-
9 files changed, 1013 insertions(+), 62 deletions(-)
create mode 100644
samza-core/src/main/java/org/apache/samza/clustermanager/container/placements/ContainerPlacementMetadata.java
create mode 100644
samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerPlacementActions.java
