This is an automated email from the ASF dual-hosted git repository.
suvasude pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git.
from 1367614 [GOBBLIN-1497] Reduce the number of calls on FlowSpec
initialization where possible,… (#3340)
add 5ab79b0 [GOBBLIN-1493] Data Copy Progress Reporting (#3336)
No new revisions were added by this update.
Summary of changes:
.../gobblin/configuration/ConfigurationKeys.java | 3 +
.../apache/gobblin/service/ServiceConfigKeys.java | 4 ++
.../gobblin/cluster/GobblinHelixJobLauncher.java | 1 +
.../gobblin/data/management/copy/CopySource.java | 17 +++++-
.../data/management/copy/CopySourceTest.java | 6 +-
.../data/management/copy/TestCopyableDataset.java | 3 +-
.../apache/gobblin/metrics/event/TimingEvent.java | 2 +
.../org/apache/gobblin/service/JobStatistics.pdl | 10 ++++
...he.gobblin.service.flowexecutions.snapshot.json | 8 +++
...ache.gobblin.service.flowstatuses.snapshot.json | 8 +++
.../service/FlowExecutionResourceLocalHandler.java | 29 +++++++++-
.../FlowExecutionResourceLocalHandlerTest.java | 66 ++++++++++++++++++++++
.../gobblin/runtime/AbstractJobLauncher.java | 23 ++++++++
.../gobblin/runtime/TaskStateCollectorService.java | 62 +++++++++++++++++++-
.../gobblin/runtime/mapreduce/MRJobLauncher.java | 4 +-
.../gobblin/service/monitoring/JobStatus.java | 2 +
.../service/monitoring/JobStatusRetriever.java | 4 +-
.../runtime/TaskStateCollectorServiceTest.java | 18 +++++-
.../util/CalculateTotalWorkUnitSizeTest.java | 65 +++++++++++++++++++++
.../monitoring/KafkaAvroJobStatusMonitor.java | 3 +
20 files changed, 323 insertions(+), 15 deletions(-)
create mode 100644
gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/test/java/org/apache/gobblin/service/FlowExecutionResourceLocalHandlerTest.java
create mode 100644
gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/CalculateTotalWorkUnitSizeTest.java
