[jira] [Resolved] (SAMZA-66) MetricsSnapshotReporterFactory is specifying class instead of serde in getSerde call

["Chris Riccomini (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SAMZA-66?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chris Riccomini resolved SAMZA-66.
----------------------------------

    Resolution: Fixed

Committed.

> MetricsSnapshotReporterFactory is specifying class instead of serde in getSerde call
> ------------------------------------------------------------------------------------
>
>                 Key: SAMZA-66
>                 URL: https://issues.apache.org/jira/browse/SAMZA-66
>             Project: Samza
>          Issue Type: Bug
>          Components: metrics
>    Affects Versions: 0.6.0
>            Reporter: Chris Riccomini
>            Assignee: Chris Riccomini
>             Fix For: 0.7.0
>
>         Attachments: SAMZA-66.0.patch
>
>
> Was seeing the following stack trace when trying to use the metrics reporter:
> {noformat}
> Exception in thread "main" java.lang.RuntimeException: No schema registry defined for com.linkedin.samza.serializers.SchemaRegistrySerdeFactory
> 	at com.linkedin.samza.serializers.SchemaRegistrySerdeFactory.getSerde(SchemaRegistrySerde.scala:45)
> 	at org.apache.samza.metrics.reporter.MetricsSnapshotReporterFactory.getMetricsReporter(MetricsSnapshotReporterFactory.scala:101)
> 	at org.apache.samza.job.yarn.SamzaAppMasterMetrics$$anonfun$9.apply(SamzaAppMasterMetrics.scala:63)
> 	at org.apache.samza.job.yarn.SamzaAppMasterMetrics$$anonfun$9.apply(SamzaAppMasterMetrics.scala:55)
> 	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
> 	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
> 	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
> 	at scala.collection.immutable.List.foreach(List.scala:45)
> 	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
> 	at scala.collection.immutable.List.map(List.scala:45)
> 	at org.apache.samza.job.yarn.SamzaAppMasterMetrics.<init>(SamzaAppMasterMetrics.scala:55)
> 	at org.apache.samza.job.yarn.SamzaAppMaster$.main(SamzaAppMaster.scala:76)
> 	at org.apache.samza.job.yarn.SamzaAppMaster.main(SamzaAppMaster.scala)
> {noformat}
> This error is triggered because it appears that the metrics reporter is calling getSerde with the class name instead of the serde name.



--
This message was sent by Atlassian JIRA
(v6.1#6144)