[
https://issues.apache.org/jira/browse/SAMZA-1266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998918#comment-15998918
]
ASF GitHub Bot commented on SAMZA-1266:
---------------------------------------
GitHub user jmakes opened a pull request:
https://github.com/apache/samza/pull/167
SAMZA-1266: Unable to use MetricsSnapshotReporterFactory with fluent API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jmakes/samza samza-1266
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/167.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #167
----
commit fe6760f52a7704c29fe0a56696267176187f0006
Author: Jacob Maes <[email protected]>
Date: 2017-05-05T20:34:23Z
SAMZA-1266: Unable to use MetricsSnapshotReporterFactory with fluent API
----
> 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)
