You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2013/10/23 23:25:22 UTC
git commit: SAMZA-66;
use serde, not serde class, in metrics snapshot reporter
Updated Branches:
refs/heads/master 32d51a018 -> 8ea21df75
SAMZA-66; use serde, not serde class, in metrics snapshot reporter
Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/8ea21df7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/8ea21df7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/8ea21df7
Branch: refs/heads/master
Commit: 8ea21df752d980c32b1f0c48f6d536ef83e913d5
Parents: 32d51a0
Author: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Authored: Wed Oct 23 14:25:10 2013 -0700
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Committed: Wed Oct 23 14:25:10 2013 -0700
----------------------------------------------------------------------
.../samza/metrics/reporter/MetricsSnapshotReporterFactory.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/8ea21df7/samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsSnapshotReporterFactory.scala
----------------------------------------------------------------------
diff --git a/samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsSnapshotReporterFactory.scala b/samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsSnapshotReporterFactory.scala
index f20dc36..9711043 100644
--- a/samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsSnapshotReporterFactory.scala
+++ b/samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsSnapshotReporterFactory.scala
@@ -95,9 +95,9 @@ class MetricsSnapshotReporterFactory extends MetricsReporterFactory with Logging
val serdeName = streamSerdeName.getOrElse(systemSerdeName.getOrElse(null))
val serde = if (serdeName != null) {
config.getSerdeClass(serdeName) match {
- case Some(serdeName) =>
+ case Some(serdeClassName) =>
Util
- .getObj[SerdeFactory[MetricsSnapshot]](serdeName)
+ .getObj[SerdeFactory[MetricsSnapshot]](serdeClassName)
.getSerde(serdeName, config)
case _ => null
}