Samza - Apache Samza 1.5 <a href="/learn/documentation/1.5.0/"> [Docs] </a>

<!DOCTYPE html>  <html lang="en"> <head> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no"> <meta charset="utf-8"> <title>Samza - Apache Samza 1.5 <a href="/learn/documentation/1.5.0/"> [Docs] </a></title> <link rel="apple-touch-icon-precomposed" sizes="57x57" href="/img/favicon/apple-touch-icon-57x57.png" /> <link rel="apple-touch-icon-precomposed" sizes="114x114" href="/img/favicon/apple-touch-icon-114x114.png" /> <link rel="apple-touch-icon-precomposed" sizes="72x72" href="/img/favicon/apple-touch-icon-72x72.png" /> <link rel="apple-touch-icon-precomposed" sizes="144x144" href="/img/favicon/apple-touch-icon-144x144.png" /> <link rel="apple-touch-icon-precomposed" sizes="60x60" href="/img/favicon/apple-touch-icon-60x60.png" /> <link rel="apple-touch-icon-precomposed" sizes="120x120" href="/img/favicon/apple-touch-icon-120x120.png" /> <link rel="apple-touch-icon-precomposed" sizes="76x76" href="/img/favicon/apple-touch-icon-76x76.png" /> <link rel="apple-touch-icon-precomposed" sizes="152x152" href="/img/favicon/apple-touch-icon-152x152.png" /> <link rel="icon" type="image/png" href="/img/favicon/favicon-196x196.png" sizes="196x196" /> <link rel="icon" type="image/png" href="/img/favicon/favicon-96x96.png" sizes="96x96" /> <link rel="icon" type="image/png" href="/img/favicon/favicon-32x32.png" sizes="32x32" /> <link rel="icon" type="image/png" href="/img/favicon/favicon-16x16.png" sizes="16x16" /> <link rel="icon" type="image/png" href="/img/favicon/favicon-128.png" sizes="128x128" /> <meta name="application-name" content="https://samza.apache.org" /> <meta name="msapplication-TileColor" content="#FFFFFF" /> <meta name="msapplication-TileImage" content="/img/favicon/mstile-144x144.png" /> <meta name="msapplication-square70x70logo" content="/img/favicon/mstile-70x70.png" /> <meta name="msapplication-square150x150logo" content="/img/favicon/mstile-150x150.png" /> <meta name="msapplication-wide310x150logo" content="/img/favicon/mstile-310x150.png" /> <meta name="msapplication-square310x310logo" content="/img/favicon/mstile-310x310.png" /> <link href="/css/ionicons.min.css" rel="stylesheet"> <link href="/css/google-fonts.css" rel="stylesheet"> <link href="/css/syntax.css" rel="stylesheet"/> <link rel="stylesheet" href="/css/main.new.css" /> </head> <body class="page">  <div class="main-navigation" data-plugin="menu"> <div class="main-navigation__toggle" data-menu-closed> <i class="icon ion-md-menu"></i> </div> <div class="main-navigation__toggle main-navigation__toggle--opened" data-menu-opened> <i class="icon ion-md-close"></i> </div> <div class="main-navigation__inner"> <div class="main-navigation__logo"> <a href="/"> <img class="main-navigation__logo-img" src="/img/samza-logo.png" srcset="/img/samza-logo.png 1x, /img/samza-logo@2x.png 2x" alt="Samza Logo" /> </a> </div> <div class="main-navigation__items" data-menu-opened> <a class="main-navigation__item" href="/">Home</a> <a class="main-navigation__item" href="/learn/documentation/latest/core-concepts/core-concepts.html">Docs</a> <a class="main-navigation__item" href="/powered-by/">Powered By</a> <a class="main-navigation__item" href="/startup/download/">Downloads</a> <a class="main-navigation__item" href="/blog/">Blog</a> <div class="main-navigation__item main-navigation__item--group"> <div class="main-navigation__item-group-title"> Community <i class="icon ion-md-arrow-dropdown"></i> </div> <div class="main-navigation__item-group-list"> <a class="main-navigation__item" href="/community/contact-us.html">Contact Us</a> <a class="main-navigation__item" href="/contribute/contributors-corner.html">Contributor's Corner</a> <a class="main-navigation__item" href="/community/committers.html">PMC Members and committers</a> <a class="main-navigation__item" href="/meetups/">Talks and Meetups</a> </div> </div> </div> </div> </div> <div class="container"> <div class="container__toggle"> <i class="icon ion-md-arrow-dropleft-circle container__toggle-icon"></i> <i class="icon ion-md-arrow-dropright-circle container__toggle-icon container__toggle-icon--opened"></i> </div>   <div class="side-navigation">  <div class="side-navigation__group side-navigation__group--has-nested" data-plugin="sub-menu" data-sub-menu-show-class="side-navigation__group--has-nested-visible">  <div class="side-navigation__group-title"> <i class="side-navigation__group-title-icon icon ion-md-arrow-dropdown"></i> Getting Started </div> <div class="side-navigation__group-items " data-sub-menu >  <a class="side-navigation__group-item" data-match-active="" href="/startup/quick-start/latest/">QuickStart</a> <a class="side-navigation__group-item" data-match-active="" href="/startup/code-examples/latest/">Code Examples</a>   </div>  </div>  <div class="side-navigation__group side-navigation__group--has-nested" data-plugin="sub-menu" data-sub-menu-show-class="side-navigation__group--has-nested-visible">  <div class="side-navigation__group-title"> <i class="side-navigation__group-title-icon icon ion-md-arrow-dropdown"></i> Documentation </div> <div class="side-navigation__group-items side-navigation__group-has-submenus" data-sub-menu data-documentation="/learn/documentation/latest/">    </div>  </div>  <div class="side-navigation__group side-navigation__group--has-nested" data-plugin="sub-menu" data-sub-menu-show-class="side-navigation__group--has-nested-visible">  <div class="side-navigation__group-title"> <i class="side-navigation__group-title-icon icon ion-md-arrow-dropdown"></i> Releases </div> <div class="side-navigation__group-items " data-sub-menu >  <a class="side-navigation__group-item" data-match-active="" href="/releases/1.8.0">1.8.0</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.7.0">1.7.0</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.6.0">1.6.0</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.5.1">1.5.1</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.5.0">1.5.0</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.4.0">1.4.0</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.3.1">1.3.1</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.3.0">1.3.0</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.2.0">1.2.0</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.1.0">1.1.0</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/1.0.0">1.0.0</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/0.14">0.14</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/0.13">0.13</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/0.12">0.12</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/0.11">0.11</a> <a class="side-navigation__group-item" data-match-active="" href="/releases/0.10">0.10</a>   </div>  </div>  <div class="side-navigation__group">  <a class="side-navigation__group-title" data-plugin="top-menu" data-match-active="" href="/blog/"> Blog </a>     </div>  <div class="side-navigation__group side-navigation__group--has-nested" data-plugin="sub-menu" data-sub-menu-show-class="side-navigation__group--has-nested-visible">  <div class="side-navigation__group-title"> <i class="side-navigation__group-title-icon icon ion-md-arrow-dropdown"></i> Community </div> <div class="side-navigation__group-items " data-sub-menu >  <a class="side-navigation__group-item" data-match-active="" href="/community/contact-us.html">Contact Us</a> <a class="side-navigation__group-item" data-match-active="" href="/contribute/contributors-corner.html">Contributor's Corner</a> <a class="side-navigation__group-item" data-match-active="" href="/contribute/enhancement-proposal.html">Enhancement Proposal</a> <a class="side-navigation__group-item" data-match-active="" href="/community/committers.html">PMC members & Committers</a> <a class="side-navigation__group-item" data-match-active="" href="/meetups/">Talks and Meetups</a>   </div>  </div>  <div class="side-navigation__group side-navigation__group--has-nested" data-plugin="sub-menu" data-sub-menu-show-class="side-navigation__group--has-nested-visible">  <div class="side-navigation__group-title"> <i class="side-navigation__group-title-icon icon ion-md-arrow-dropdown"></i> Case Studies </div> <div class="side-navigation__group-items " data-sub-menu >  <a class="side-navigation__group-item" data-match-active="exact" href="/case-studies/">View All</a> <hr>  <a class="side-navigation__group-item" href="/case-studies/ebay" data-match-active="">eBay</a> <a class="side-navigation__group-item" href="/case-studies/tripadvisor" data-match-active="">TripAdvisor</a> <a class="side-navigation__group-item" href="/case-studies/slack" data-match-active="">Slack</a> <a class="side-navigation__group-item" href="/case-studies/optimizely" data-match-active="">Optimizely</a> <a class="side-navigation__group-item" href="/case-studies/redfin" data-match-active="">Redfin</a> <a class="side-navigation__group-item" href="/case-studies/linkedin" data-match-active="">LinkedIn</a>  </div>  </div> </div> <div class="section"> <div class="content"> <h2>Apache Samza 1.5 <a href="/learn/documentation/1.5.0/"> [Docs] </a></h2>  <p><strong>IMPORTANT NOTE</strong>: As noted in the last release, this release contains <strong>backward incompatible changes regarding samza job submission</strong>. Details can be found on <a href="https://cwiki.apache.org/confluence/display/SAMZA/SEP-23%3A+Simplify+Job+Runner">SEP-23: Simplify Job Runner</a></p> <p>We are thrilled to announce the release of Apache Samza 1.5.0.</p> <p>Today, Samza forms the backbone of hundreds of real-time production applications across a multitude of companies, such as LinkedIn, Slack, and Redfin, among many others. Samza provides leading support for large-scale stateful stream processing with:</p> <ul> <li> <p>First class support for local states (with RocksDB store). This allows a stateful application to scale up to 1.1 Million events/sec on a single machine with SSD.</p> </li> <li> <p>Support for incremental checkpointing of state instead of full snapshots. This enables Samza to scale to applications with very large states.</p> </li> <li> <p>A fully asynchronous programming model that makes parallelizing remote calls efficient and effortless.</p> </li> <li> <p>High level API for expressing complex stream processing pipelines in a few lines of code.</p> </li> <li> <p>Beam Samza Runner that marries Beam’s best in class support for EventTime based windowed processing and sophisticated triggering with Samza’s stable and scalable stateful processing model.</p> </li> <li> <p>A fully pluggable model for input sources (e.g. Kafka, Kinesis, DynamoDB streams etc.) and output systems (HDFS, Kafka, ElastiCache etc.).</p> </li> <li> <p>A Table API that provides a common abstraction for accessing remote or local databases and allows developers to “join” an input event stream with such a Table.</p> </li> <li> <p>Flexible deployment model for running the applications in any hosting environment and with cluster managers other than YARN.</p> </li> </ul> <h3 id="new-features-upgrades-and-bug-fixes">New Features, Upgrades and Bug Fixes:</h3> <p>This release brings the following features, upgrades, and capabilities (highlights):</p> <h4 id="samza-container-placement">Samza Container Placement</h4> <p>Container Placements API gives you the ability to move / restart one or more containers (either active or standby) of your cluster based applications from one host to another without restarting your application. You can use these api to build maintenance, balancing & remediation tools.</p> <h4 id="simplify-job-runner--configs">Simplify Job Runner & Configs</h4> <p>Job Runner will now simply submit Samza job to Yarn RM without executing any user code and job planning will happen on ClusterBasedJobCoordinator instead. This simplified workflow addresses security requirements where job submissions need to be isolated in order to execute user code as well as operational pain points where deployment failure could happen at multiple places.</p> <p>Full list of the jiras addressed in this release can be found <a href="https://issues.apache.org/jira/issues/?jql=project%20%3D%20SAMZA%20and%20fixVersion%20in%20(1.5)">here</a>.</p> <h3 id="upgrading-your-application-to-apache-samza-150">Upgrading your application to Apache Samza 1.5.0</h3> <p>ConfigFactory is deprecated as Job Runner does not load full job config anymore. Instead, ConfigLoaderFactory is introduced to be executed on ClusterBasedJobCoordinator to fetch full job config. If you are using the default PropertiesConfigFactory, simply switching to use the default PropertiesConfigLoaderFactory will work, otherwise if you are using a custom ConfigFactory, kindly creates its new counterpart following ConfigLoaderFactory.</p> <p>Configs related to job submission must be explicitly provided to Job Runner as it is no longer loading full job config anymore. These configs include</p> <ul> <li>Configs directly related to job submission, such as yarn.package.path, job.name etc.</li> <li>Configs needed by the config loader on AM to fetch job config, such as path to the property file in the tarball, all of such configs will have a job.config.loader.properties prefix.</li> <li>Configs that users would like to override</li> </ul> <p>Full list of the job submission configurations can be found <a href="https://cwiki.apache.org/confluence/display/SAMZA/SEP-23%3A+Simplify+Job+Runner#SEP23:SimplifyJobRunner-References">here</a></p> <h4 id="usage-instructions">Usage Instructions</h4> <p>Alternative way when submitting job,</p> <figure class="highlight"><pre><code class="language-bash" data-lang="bash">deploy/samza/bin/run-app.sh <span class="nt">--config</span> yarn.package.path<span class="o">=</span><package_path> <span class="nt">--config</span> job.name<span class="o">=</span><job_name></code></pre></figure> <p>can be simplified to</p> <figure class="highlight"><pre><code class="language-bash" data-lang="bash">deploy/samza/bin/run-app.sh <span class="nt">--config-path</span><span class="o">=</span>/path/to/submission/properties/file/submission.properties</code></pre></figure> <p>where submission.properties contains</p> <figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties">yarn.package.path=<package_path> job.name=<job_name></code></pre></figure> <h4 id="rollback-instructions">Rollback Instructions</h4> <p>In case of a problem in Samza 1.5, users can rollback to Samza 1.4 and keep the old start up flow using <em>config-path</em> & <em>config-factory</em>.</p> <h3 id="simplify-job-runner">Simplify Job Runner</h3> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2488">SAMZA-2488</a> Add JobCoordinatorLaunchUtil to handle common logic when launching job coordinator</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2471">SAMZA-2471</a> Simplify CommandLine</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2458">SAMZA-2458</a> Update ProcessJobFactory and ThreadJobFactory to load full job config</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2453">SAMZA-2453</a> Update ClusterBasedJobCoordinator to support Beam jobs</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2441">SAMZA-2441</a> Update ApplicationRunnerMain#ApplicationRunnerCommandLine not to load local file</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2420">SAMZA-2420</a> Update CommandLine to use config loader for local config file</p> <h3 id="container-placement-api">Container Placement API</h3> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2402">SAMZA-2402</a> Tie Container placement service and Container placement handler and validate placement requests</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2379">SAMZA-2379</a> Support Container Placements for job running in degraded state</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2378">SAMZA-2378</a> Container Placements support for Standby containers enabled jobs</p> <h3 id="bug-fixes">Bug Fixes</h3> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2515">SAMZA-2515</a> Thread safety for Kafka consumer in KafkaConsumerProxy</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2511">SAMZA-2511</a> Handle container-stop-fail in case of standby container failover</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2510">SAMZA-2510</a> Incorrect shutdown status due to race between runloop thread and process callback thread</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2506">SAMZA-2506</a> Inconsistent end of stream semantics in SystemStreamPartitionMetadata</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2464">SAMZA-2464</a> Container shuts down when task fails to remove old state checkpoint dirs</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2468">SAMZA-2468</a> Standby container needs to respond to shutdown request</p> <h3 id="other-improvements">Other Improvements</h3> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2519">SAMZA-2519</a> Support duplicate timer registration</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2508">SAMZA-2508</a> Use cytodynamics classloader to launch job container</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2478">SAMZA-2478</a> Add new metrics to track key and value size of records written to RocksDb</p> <p><a href="https://issues.apache.org/jira/browse/SAMZA-2462">SAMZA-2462</a> Adding metric for container thread pool size</p> <h3 id="sources-downloads">Sources downloads</h3> <p>A source download of Samza 1.5.0 is available <a href="https://dist.apache.org/repos/dist/release/samza/1.5.0/">here</a>, and is also available in Apache’s Maven repository. See Samza’s download <a href="https://samza.apache.org/startup/download/">page</a> for details and Samza’s feature preview for new features.</p> </div> </div> </div>   <footer> <div class="footer-inner"> <div class="side-by-side"> <div> <div class="footer__heading">Learn More</div> <div class="footer__items"> <a class="footer__item" href="/meetups/">Meetups</a> <a class="footer__item" href="/blog/">Blog</a> <a class="footer__item" href="/learn/documentation/latest/introduction/background.html">About</a> </div> </div> <div> <div class="footer__heading">Community</div> <div class="footer__items"> <a class="footer__item" href="/community/contact-us.html">Contact Us</a> <a class="footer__item" href="/contribute/contributors-corner.html">Contributors' Corner</a> <a class="footer__item" href="/community/committers.html">PMC members and committers</a> <a class="footer__item" href="/powered-by/">Powered By</a> </div> </div> <div> <div class="quick-links"> <a class="quick-link" href="/startup/download" target="_blank"> <i class="icon ion-md-download"></i> </a> <a class="quick-link" href="https://git-wip-us.apache.org/repos/asf?p=samza.git;a=tree" target="_blank"> <i class="icon ion-md-code"></i> </a> <a class="quick-link" href="https://twitter.com/samzastream" target="_blank"> <i class="icon ion-logo-twitter"></i> </a> </div> <p> <script>document.write(new Date().getFullYear());</script> © samza.apache.org</p> </div> </div> </div> </footer>  <script> (function (i, s, o, g, r, a, m) { i['GoogleAnalyticsObject'] = r; i[r] = i[r] || function () { (i[r].q = i[r].q || []).push(arguments) }, i[r].l = 1 * new Date(); a = s.createElement(o), m = s.getElementsByTagName(o)[0]; a.async = 1; a.src = g; m.parentNode.insertBefore(a, m) })(window, document, 'script', '//www.google-analytics.com/analytics.js', 'ga'); ga('create', 'UA-43122768-1', 'apache.org'); ga('send', 'pageview'); </script> <script src="/js/main.new.js"></script> </body> </html>

CINXE.COM

Samza - Apache Samza 1.5 [Docs]