You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "David Chen (JIRA)" <ji...@apache.org> on 2014/06/18 10:36:05 UTC

[jira] [Commented] (SAMZA-287) Expose config via AM REST interface

    [ https://issues.apache.org/jira/browse/SAMZA-287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14035234#comment-14035234 ] 

David Chen commented on SAMZA-287:
----------------------------------

I have a patch that adds a new REST endpoint {{GET /config}}, which dumps the config as JSON. For the wikipedia-feed job in hello-samza, the endpoint returns the following JSON (formatted):

{code}
{
    "job.factory.class": "org.apache.samza.job.yarn.YarnJobFactory",
    "job.name": "wikipedia-feed",
    "serializers.registry.json.class": "org.apache.samza.serializers.JsonSerdeFactory",
    "systems.kafka.consumer.zookeeper.connect": "localhost:2181/",
    "systems.kafka.producer.batch.num.messages": "1",
    "systems.kafka.producer.metadata.broker.list": "localhost:9092",
    "systems.kafka.producer.producer.type": "sync",
    "systems.kafka.samza.factory": "org.apache.samza.system.kafka.KafkaSystemFactory",
    "systems.kafka.samza.msg.serde": "json",
    "systems.wikipedia.host": "irc.wikimedia.org",
    "systems.wikipedia.port": "6667",
    "systems.wikipedia.samza.factory": "samza.examples.wikipedia.system.WikipediaSystemFactory",
    "task.class": "samza.examples.wikipedia.task.WikipediaFeedStreamTask",
    "task.inputs": "wikipedia.#en.wikipedia,wikipedia.#en.wiktionary,wikipedia.#en.wikinews",
    "yarn.package.path": "file:///Users/dzc/Projects/hello-samza/samza-job-package/target/samza-job-package-0.7.0-dist.tar.gz"
}
{code}

> Expose config via AM REST interface
> -----------------------------------
>
>                 Key: SAMZA-287
>                 URL: https://issues.apache.org/jira/browse/SAMZA-287
>             Project: Samza
>          Issue Type: Improvement
>            Reporter: David Chen
>            Assignee: David Chen
>         Attachments: SAMZA-287.1.patch
>
>
> While the AM web UI provides the config, the AM REST API does not have an interface that exposes the config. Add a REST interface for exposing the config.



--
This message was sent by Atlassian JIRA
(v6.2#6252)