This is an automated email from the ASF dual-hosted git repository.
zihanli58 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git
from bbd18f33c [GOBBLIN-1706] Add DagActionStore to store the action to
kill/resume one flow execution (#3558)
add 31f7ec5b7 [GOBBLIN-1705] New consumer service to monitor changes to
FlowSpecStore (#3557)
No new revisions were added by this update.
Summary of changes:
.../src/main/avro/SpecStoreChangeEvent.avsc | 32 ++++
.../gobblin/runtime/metrics/RuntimeMetrics.java | 7 +
.../modules/core/GobblinServiceGuiceModule.java | 6 +
.../modules/core/GobblinServiceManager.java | 8 +
.../scheduler/GobblinServiceJobScheduler.java | 5 +
.../service/monitoring/SpecStoreChangeMonitor.java | 164 +++++++++++++++++++++
.../monitoring/SpecStoreChangeMonitorFactory.java | 66 +++++++++
7 files changed, 288 insertions(+)
create mode 100644
gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/SpecStoreChangeEvent.avsc
create mode 100644
gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java
create mode 100644
gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitorFactory.java
