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 <[email protected]> Authored: Wed Oct 23 14:25:10 2013 -0700 Committer: Chris Riccomini <[email protected]> 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 }
