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 <bor...@apache.org> Authored: Wed Aug 22 11:31:26 2018 -0700 Committer: Boris S <bor...@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(-) ----------------------------------------------------------------------
