You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Ke Wu (Confluence)" <no...@apache.org> on 2020/03/06 19:20:00 UTC

[CONF] Apache Samza > SEP-23: Simplify Job Runner

There's **1 new edit** on this page  
---  
|  
---  
|  | [![page icon](cid:page-
icon)](https://cwiki.apache.org/confluence/display/SAMZA/SEP-23%3A+Simplify+Job+Runner?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1583522400579&src.mail.notification=com.atlassian.confluence.plugins.confluence-
notifications-batch-plugin%3Abatching-
notification&src.mail.recipient=8aa980875bf24635015c82a7d09902ac&src.mail.action=view
"page icon")  
---  
[SEP-23: Simplify Job
Runner](https://cwiki.apache.org/confluence/display/SAMZA/SEP-23%3A+Simplify+Job+Runner?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1583522400579&src.mail.notification=com.atlassian.confluence.plugins.confluence-
notifications-batch-plugin%3Abatching-
notification&src.mail.recipient=8aa980875bf24635015c82a7d09902ac&src.mail.action=view
"SEP-23: Simplify Job Runner")  
|  |  |  |  | ![](cid:avatar_9f2697819e37c875ff50f49ce698f1ef) |  | Ke Wu
edited this page  
---  
|  
|  | Here's what changed:  
---  
|

...

|
![](https://cwiki.apache.org/confluence/s/-7iq2vk/8301/13280cd41a592ca5883bbc1ae415b58671505365/_/plugins/servlet/confluence/placeholder/macro-
icon?name=code) Code Block  
---  
      
    
    deploy/samza/bin/run-app.sh \
      --config app.class=samza.examples.wikipedia.task.application.WikipediaFeedTaskApplication \
      --config job.name=wikipedia-stats \
      --config job.factory.class=org.apache.samza.job.yarn.YarnJobFactory \
      --config yarn.package.path=file://${basedir}/target/${project.artifactId}-${pom.version}-dist.tar.gz \
      --config job.config.loader.factory=org.apache.samza.config.loaders.PropertiesConfigLoaderFactory \
      --config job.config.loader.properties.path=/__package/config/wikipedia-feed.properties  
  
#  **Work with Beam**

See [Work with Beam](/confluence/pages/viewpage.action?pageId=148640868) on
how Samza Beam jobs work with simplified Job Runner.

#  **Rejected Alternatives**

The above approach requires existing users to update its way to start a Samza
job. Alternatively, we may keep the ability for runner to read from a local
config, and AM will load the config using with the loader again.

...  
  
|  |  | [Go to page
history](https://cwiki.apache.org/confluence/pages/viewpreviousversions.action?pageId=135861183&src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1583522400579&src.mail.notification=com.atlassian.confluence.plugins.confluence-
notifications-batch-plugin%3Abatching-
notification&src.mail.recipient=8aa980875bf24635015c82a7d09902ac "Go to page
history")  
---  
---  
| [View
page](https://cwiki.apache.org/confluence/display/SAMZA/SEP-23%3A+Simplify+Job+Runner?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1583522400579&src.mail.notification=com.atlassian.confluence.plugins.confluence-
notifications-batch-plugin%3Abatching-
notification&src.mail.recipient=8aa980875bf24635015c82a7d09902ac&src.mail.action=view)  
---  
  
|  | [Stop watching
space](https://cwiki.apache.org/confluence/users/removespacenotification.action?spaceKey=SAMZA&src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1583522400579&src.mail.notification=com.atlassian.confluence.plugins.confluence-
notifications-batch-plugin%3Abatching-
notification&src.mail.recipient=8aa980875bf24635015c82a7d09902ac&src.mail.action=stop-
watching&jwt=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJ4c3JmOjhhYTk4MDg3NWJmMjQ2MzUwMTVjODJhN2QwOTkwMmFjIiwicXNoIjoiZTE1YzQ3NmU1MTY0ZDU0MmIyMjEwYjI2MzVkMTlkYjAyNzZhNWEyMWNkOTJkODc3NGZkOWNiMzBmYTU5NTAyOSIsImlzcyI6ImNvbmZsdWVuY2Vfbm90aWZpY2F0aW9uc0FSRUgtWFVEMS1QT1FHLUNTQU8iLCJleHAiOjE1ODQxMjcyMDAsImlhdCI6MTU4MzUyMjQwMH0.Qsd0Ztrj9mRdumwhkeksO8G7aOuGez4TnSv12Daia5M)
| •  
---|---  
[Manage
notifications](https://cwiki.apache.org/confluence/users/editmyemailsettings.action?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1583522400579&src.mail.notification=com.atlassian.confluence.plugins.confluence-
notifications-batch-plugin%3Abatching-
notification&src.mail.recipient=8aa980875bf24635015c82a7d09902ac&src.mail.action=manage)  
---  
| ![Confluence logo big](cid:footer-desktop-logo)  
---  
This message was sent by Atlassian Confluence 7.1.2  
![](cid:footer-mobile-logo)  
---