[SAMZA-1266] Unable to use MetricsSnapshotReporterFactory with fluent API

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.13.0
• Assignee: Jake Maes
• Reporter: Jake Maes
• Created: 05/May/17 16:46
• Updated: 04/Oct/17 18:52
• Resolved: 05/May/17 22:54

Description

MetricsSnapshotReporterFactory requires task.class property in the config, but that property is not set in the fluent API. The result is the following error:

Exception in thread "main" org.apache.samza.SamzaException: No task class defined for config.
	at org.apache.samza.metrics.reporter.MetricsSnapshotReporterFactory$$anonfun$3.apply(MetricsSnapshotReporterFactory.scala:52)
	at org.apache.samza.metrics.reporter.MetricsSnapshotReporterFactory$$anonfun$3.apply(MetricsSnapshotReporterFactory.scala:52)
	at scala.Option.getOrElse(Option.scala:121)
	at org.apache.samza.metrics.reporter.MetricsSnapshotReporterFactory.getMetricsReporter(MetricsSnapshotReporterFactory.scala:52)
	at org.apache.samza.util.MetricsReporterLoader.getMetricsReporters(MetricsReporterLoader.java:47)
	at org.apache.samza.job.yarn.SamzaAppMasterMetrics.<init>(SamzaAppMasterMetrics.scala:46)
	at org.apache.samza.job.yarn.YarnClusterResourceManager.<init>(YarnClusterResourceManager.java:133)
	at org.apache.samza.job.yarn.YarnResourceManagerFactory.getClusterResourceManager(YarnResourceManagerFactory.java:41)
	at org.apache.samza.clustermanager.ContainerProcessManager.<init>(ContainerProcessManager.java:111)
	at org.apache.samza.clustermanager.ClusterBasedJobCoordinator.<init>(ClusterBasedJobCoordinator.java:128)
	at org.apache.samza.clustermanager.ClusterBasedJobCoordinator.main(ClusterBasedJobCoordinator.java:221)

Issue Links

• is duplicated by: SAMZA-1328 MetricsReporterFactory requires app.class even though its optional
• links to: GitHub Pull Request #167