[
https://issues.apache.org/jira/browse/SAMZA-1266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jake Maes resolved SAMZA-1266.
------------------------------
Resolution: Fixed
Issue resolved by pull request 167
[https://github.com/apache/samza/pull/167]
> Unable to use MetricsSnapshotReporterFactory with fluent API
> ------------------------------------------------------------
>
> Key: SAMZA-1266
> URL: https://issues.apache.org/jira/browse/SAMZA-1266
> Project: Samza
> Issue Type: Bug
> Reporter: Jake Maes
> Assignee: Jake Maes
> Fix For: 0.13.0
>
>
> MetricsSnapshotReporterFactory requires task.class property in the config,
> but that property is not set in the fluent API. The result is the following
> error:
> {noFormat}
> 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)
> {noFormat}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
