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