[SAMZA-66] MetricsSnapshotReporterFactory is specifying class instead of serde in getSerde call

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.6.0
• Fix Version/s: 0.7.0
• Component/s: metrics
• Assignee: Chris Riccomini
• Reporter: Chris Riccomini
• Created: 24/Oct/13 00:35
• Updated: 24/Oct/13 01:31
• Resolved: 24/Oct/13 01:31

Description

Was seeing the following stack trace when trying to use the metrics reporter:

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)

This error is triggered because it appears that the metrics reporter is calling getSerde with the class name instead of the serde name.