You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ca...@apache.org on 2021/10/27 22:46:11 UTC
[samza] branch master updated (96d4b80 -> 1348d51)
This is an automated email from the ASF dual-hosted git repository.
cameronlee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from 96d4b80 Using TCK Tested JDK builds of OpenJDK (#1545)
add 1348d51 SAMZA-2703: Add input stream partition count and input stream regex monitoring for refreshing job model (#1548)
No new revisions were added by this update.
Summary of changes:
.../lifecycle/JobRestartSignal.java} | 21 +-
.../lifecycle/JobRestartSignalFactory.java | 10 +-
.../lifecycle/JobRestartSignalFactoryContext.java} | 39 ++--
.../clustermanager/JobCoordinatorLaunchUtil.java | 2 +-
.../apache/samza/config/JobCoordinatorConfig.java | 9 +-
.../apache/samza/coordinator/JobModelMonitors.java | 61 ++++++
.../communication/CoordinatorCommunication.java | 2 +-
.../lifecycle/NoOpJobRestartSignal.java} | 19 +-
.../lifecycle/NoOpJobRestartSignalFactory.java | 12 +-
.../StaticResourceJobCoordinator.java | 86 +++++++-
.../StaticResourceJobCoordinatorFactory.java | 19 +-
.../TestJobCoordinatorLaunchUtil.java | 18 +-
.../samza/config/TestJobCoordinatorConfig.java | 12 ++
...atorListener.java => TestJobModelMonitors.java} | 37 ++--
.../TestStaticResourceJobCoordinator.java | 217 ++++++++++++++++++---
15 files changed, 439 insertions(+), 125 deletions(-)
copy samza-api/src/main/java/org/apache/samza/{config/ConfigFactory.java => coordinator/lifecycle/JobRestartSignal.java} (51%)
copy samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainType.java => samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignalFactory.java (81%)
copy samza-api/src/main/java/org/apache/samza/{context/JobContext.java => coordinator/lifecycle/JobRestartSignalFactoryContext.java} (58%)
create mode 100644 samza-core/src/main/java/org/apache/samza/coordinator/JobModelMonitors.java
copy samza-core/src/main/java/org/apache/samza/{container/disk/NoThrottlingDiskQuotaPolicy.java => coordinator/lifecycle/NoOpJobRestartSignal.java} (66%)
copy samza-api/src/main/java/org/apache/samza/serializers/ByteSerdeFactory.java => samza-core/src/main/java/org/apache/samza/coordinator/lifecycle/NoOpJobRestartSignalFactory.java (77%)
copy samza-core/src/test/java/org/apache/samza/coordinator/{TestNoProcessorJobCoordinatorListener.java => TestJobModelMonitors.java} (50%)