You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by bo...@apache.org on 2018/09/18 23:01:16 UTC
[19/47] samza git commit: Merge branch 'master' of
https://github.com/apache/samza
Merge branch 'master' of https://github.com/apache/samza
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/7f7b5594
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/7f7b5594
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/7f7b5594
Branch: refs/heads/NewKafkaSystemConsumer
Commit: 7f7b5594c21e9e3ebf25d243cbf078dbf6201a0f
Parents: 57fca52 a9ff093
Author: Boris S <bo...@apache.org>
Authored: Wed Aug 22 11:31:26 2018 -0700
Committer: Boris S <bo...@apache.org>
Committed: Wed Aug 22 11:31:26 2018 -0700
----------------------------------------------------------------------
.../samza/execution/ExecutionPlanner.java | 20 +++++---
.../runtime/AbstractApplicationRunner.java | 20 +++++---
.../samza/runtime/LocalApplicationRunner.java | 41 ++++++++--------
.../samza/runtime/RemoteApplicationRunner.java | 36 +++++++-------
.../org/apache/samza/config/MetricsConfig.scala | 11 +++--
.../diagnostics/DiagnosticsExceptionEvent.java | 6 +--
.../scala/org/apache/samza/job/JobRunner.scala | 2 +-
.../reporter/MetricsSnapshotReporter.scala | 35 +++++++-------
.../MetricsSnapshotReporterFactory.scala | 6 +--
.../runtime/TestLocalApplicationRunner.java | 50 ++++++++++++--------
10 files changed, 129 insertions(+), 98 deletions(-)
----------------------------------------------------------------------