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%)