You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by na...@apache.org on 2017/05/10 01:24:18 UTC
samza git commit: SAMZA-1276 : Adding customReporters passed by
StreamProcessor into SamzaContainer
Repository: samza
Updated Branches:
refs/heads/master 8183781f2 -> c50dd080b
SAMZA-1276 : Adding customReporters passed by StreamProcessor into SamzaContainer
SamzaContainer is not adding custom reporters along side class-loaded reporters from config. This was missed in [SAMZA-1080](https://issues.apache.org/jira/browse/SAMZA-1080).
Author: Navina Ramesh <na...@apache.org>
Reviewers: Prateek Maheshwari <pm...@linkedin.com>, Jagadish <ja...@apache.org>
Closes #179 from navina/SAMZA-1276
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/c50dd080
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/c50dd080
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/c50dd080
Branch: refs/heads/master
Commit: c50dd080b80c7a64408e824a5ce189eda244b0f7
Parents: 8183781
Author: Navina Ramesh <na...@apache.org>
Authored: Tue May 9 18:24:09 2017 -0700
Committer: nramesh <nr...@linkedin.com>
Committed: Tue May 9 18:24:09 2017 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/samza/container/SamzaContainer.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/c50dd080/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
----------------------------------------------------------------------
diff --git a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
index 957cd2b..e1d7352 100644
--- a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
+++ b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
@@ -309,7 +309,7 @@ object SamzaContainer extends Logging {
info("Setting up metrics reporters.")
- val reporters = MetricsReporterLoader.getMetricsReporters(config, containerName).asScala.toMap
+ val reporters = MetricsReporterLoader.getMetricsReporters(config, containerName).asScala.toMap ++ customReporters
info("Got metrics reporters: %s" format reporters.keys)