Modified: samza/site/learn/documentation/latest/jobs/configuration-table.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/configuration-table.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/configuration-table.html (original) +++ samza/site/learn/documentation/latest/jobs/configuration-table.html Fri May 25 22:28:38 2018 @@ -472,8 +472,39 @@ <dt><code>org.apache.samza.coordinator.AzureCoordinationUtilsFactory</code></dt> <dd>Azure based coordination utils.</dd> These coordination utils are currently used for intermediate stream creation. + </dl> + </td> + </tr> + + <tr> + <td class="property" id="job.logged.store.base.dir">job.logged.store.base.dir</td> + <td class="default"> + <i>user.dir</i> environment property if set, else current working directory of the process + </td> + <td class="description"> + The base directory for changelog stores used by Samza application. Another way to configure the base directory is by setting environment variable <i>LOGGED_STORE_BASE_DIR</i>. + <b>Note:</b> The environment variable takes precedence over <i>job.logged.store.base.dir</i>. + + <br>By opting in, users are responsible for cleaning up the store directories if necessary. Jobs using host affinity should ensure that the stores are persisted across application/container restarts. + This means that the location and cleanup of this directory should be separate from the container lifecycle and resource cleanup. </td> </tr> + + <tr> + <td class="property" id="job.non-logged.store.base.dir">job.non-logged.store.base.dir</td> + <td class="default"> + <i>user.dir</i> environment property if set, else current working directory of the process + </td> + <td class="description"> + The base directory for non-changelog stores used by Samza application. + + <br>In YARN, the default behaviour without the configuration is to create non-changelog store directories in CWD which happens to be the YARN container directory. + This gets cleaned up periodically as part of NodeManager's deletion service, which is controlled by the YARN config <i>yarn.nodemanager.delete.debug-delay-sec</i>. + + <br>In non-YARN deployment models or when using a different directory other than YARN container directory, stores need to be cleaned up periodically. + </td> + </tr> + <tr> <!-- change link to StandAlone design/tutorial doc. SAMZA-1299 --> <th colspan="3" class="section" id="ZkBasedJobCoordination"><a href="../index.html">Zookeeper-based job configuration</a></th> @@ -766,6 +797,18 @@ </tr> <tr> + <td class="property" id="task-max-idle-ms">task.max.idle.ms</td> + <td class="default">10</td> + <td class="description"> + The maximum time to wait for a task worker to complete when there are no new messages to handle before resuming the main + loop and potentially polling for more messages. See <a href="#task-poll-interval-ms" class="property">task.poll.interval.ms</a> + This timeout value prevents the main loop from spinning when there is nothing for it to do. Increasing this value will reduce + the background load of the thread, but, also potentially increase message latency. It should not be set greater than the + <a href="#task-poll-interval-ms" class="property">task.poll.interval.ms</a>. + </td> + </tr> + + <tr> <td class="property" id="task-ignored-exceptions">task.ignored.exceptions</td> <td class="default"></td> <td class="description"> @@ -939,6 +982,16 @@ </tr> <tr> + <td class="property" id="systems-samza-delete-committed-messages">systems.<span class="system">system-name</span>.<br>samza.delete.committed.messages</td> + <td class="default">false</td> + <td class="description"> + If set to true, automatically delete committed messages from streams whose committed messages can be deleted. + A stream's committed messages can be deleted if it is a intermediate stream, or if user has manually + set <a href="#streams-samza-delete-committed-messages">streams.<span class="stream">stream-id</span>.<br>samza.delete.committed.messages</a> to true in the configuration. + </td> + </tr> + + <tr> <td class="property" id="systems-samza-key-serde-legacy">systems.<span class="system">system-name</span>.<br>samza.key.serde</td> <td class="default" rowspan="2"></td> <td class="description"> @@ -1093,6 +1146,16 @@ </tr> <tr> + <td class="property" id="streams-samza-delete-committed-messages">streams.<span class="stream">stream-id</span>.<br>samza.delete.committed.messages</td> + <td class="default">false</td> + <td class="description"> + If set to true, committed messages of this stream can be deleted. Committed messages of this stream will be deleted + if <a href="#systems-samza-delete-committed-messages">systems.<span class="system">system-name</span>.samza.delete.committed.messages</a> is also + set to true. + </td> + </tr> + + <tr> <td class="property" id="streams-samza-reset-offset">streams.<span class="stream">stream-id</span>.<br>samza.reset.offset</td> <td class="default">false</td> <td class="description"> @@ -2267,30 +2330,48 @@ </tr> <tr> - <td class="property" id="eventhub-stream-namespace">systems.<span class="system">system-name</span>.<br>streams.<span class="stream">stream-id</span>.<br>eventhubs.namespace</td> + <td class="property" id="eventhub-stream-namespace">streams.<span class="stream">stream-id</span>.<br>eventhubs.namespace</td> <td class="default"></td> <td class="description">Namespace of the associated <span class="stream">stream-ids</span>. Required to access the Eventhubs entity per stream.</td> </tr> <tr> - <td class="property" id="eventhub-stream-entity">systems.<span class="system">system-name</span>.<br>streams.<span class="stream">stream-id</span>.<br>eventhubs.entitypath</td> + <td class="property" id="eventhub-stream-entity">streams.<span class="stream">stream-id</span>.<br>eventhubs.entitypath</td> <td class="default"></td> <td class="description">Entity of the associated <span class="stream">stream-ids</span>. Required to access the Eventhubs entity per stream.</td> </tr> <tr> - <td class="property" id="eventhub-stream-sas-keyname">systems.<span class="system">system-name</span>.<br>streams.<span class="stream">stream-id</span>.<br>eventhubs.sas.keyname</td> + <td class="property" id="eventhub-stream-sas-keyname">sensitive.streams.<span class="stream">stream-id</span>.<br>eventhubs.sas.keyname</td> <td class="default"></td> <td class="description">SAS Keyname of the associated <span class="stream">stream-ids</span>. Required to access the Eventhubs entity per stream.</td> </tr> <tr> - <td class="property" id="eventhub-stream-sas-token">systems.<span class="system">system-name</span>.<br>streams.<span class="stream">stream-id</span>.<br>eventhubs.sas.token</td> + <td class="property" id="eventhub-stream-sas-token">sensitive.streams.<span class="stream">stream-id</span>.<br>eventhubs.sas.token</td> <td class="default"></td> <td class="description">SAS Token the associated <span class="stream">stream-ids</span>. Required to access the Eventhubs entity per stream.</td> </tr> <tr> + <td class="property" id="eventhub-client-threads">streams.<span class="system">stream-name</span>.<br>eventhubs.numClientThreads</td> + <td class="default">10</td> + <td class="description">Number of threads in thread pool that will be used by the EventHubClient. See <a href="https://docs.microsoft.com/en-us/java/api/com.microsoft.azure.eventhubs._event_hub_client.create";>here </a> for more details.</td> + </tr> + + <tr> + <td class="property" id="eventhub-prefetch-count">systems.<span class="system">system-name</span>.<br>eventhubs.prefetchCount</td> + <td class="default">999</td> + <td class="description">Number of events that EventHub client should prefetch from the server. See <a href="https://docs.microsoft.com/en-us/java/api/com.microsoft.azure.eventhubs._partition_receiver.setprefetchcount";>here </a> for more details.</td> + </tr> + + <tr> + <td class="property" id="eventhub-max-event-count">systems.<span class="system">system-name</span>.<br>eventhubs.maxEventCountPerPoll</td> + <td class="default">50</td> + <td class="description">Maximum number of events that EventHub client can return in a receive call. See <a href="https://docs.microsoft.com/en-us/java/api/com.microsoft.azure.eventhubs._partition_receive_handler.getmaxeventcount#com_microsoft_azure_eventhubs__partition_receive_handler_getMaxEventCount__";>here </a> for more details.</td> + </tr> + + <tr> <td class="property" id="eventhub-runtime-timeout">systems.<span class="system">system-name</span>.<br>eventhubs.runtime.info.timeout</td> <td class="default">60000</td> <td class="description">Timeout for fetching the runtime metadata from an Eventhub entity on startup in millis.</td> @@ -2321,7 +2402,7 @@ </tr> <tr> - <td class="property" id="eventhub-consumer-group">systems.<span class="system">system-name</span>.<br>streams.<span class="stream">stream-id</span>.<br>eventhubs.consumer.group</td> + <td class="property" id="eventhub-consumer-group">streams.<span class="stream">stream-id</span>.<br>eventhubs.consumer.group</td> <td class="default"><code>$Default</code></td> <td class="description"> Consumer only config. Set the consumer group from the upstream Eventhub that the consumer is part of. Defaults to the <code>$Default</code> group that is initially present in all Eventhub entities (unless removed)
Modified: samza/site/learn/documentation/latest/jobs/configuration.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/configuration.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/configuration.html (original) +++ samza/site/learn/documentation/latest/jobs/configuration.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/jobs/configuration.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/jobs/configuration";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -149,7 +147,7 @@ <p>All Samza jobs have a configuration file that defines the job. A very basic configuration file looks like this:</p> -<div class="highlight"><pre><code class="jproperties"><span class="c"># Job</span> +<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="c"># Job</span> <span class="na">job.factory.class</span><span class="o">=</span><span class="s">org.apache.samza.job.local.ThreadJobFactory</span> <span class="na">job.name</span><span class="o">=</span><span class="s">hello-world</span> @@ -164,7 +162,7 @@ <span class="c"># Systems</span> <span class="na">systems.example-system.samza.factory</span><span class="o">=</span><span class="s">samza.stream.example.ExampleConsumerFactory</span> <span class="na">systems.example-system.samza.key.serde</span><span class="o">=</span><span class="s">string</span> -<span class="na">systems.example-system.samza.msg.serde</span><span class="o">=</span><span class="s">json</span></code></pre></div> +<span class="na">systems.example-system.samza.msg.serde</span><span class="o">=</span><span class="s">json</span></code></pre></figure> <p>There are four major sections to a configuration file:</p> @@ -172,7 +170,7 @@ <li>The job section defines things like the name of the job, and whether to use the YarnJobFactory or ProcessJobFactory/ThreadJobFactory (See the job.factory.class property in <a href="configuration-table.html">Configuration Table</a>).</li> <li>The task section is where you specify the class name for your <a href="../api/overview.html">StreamTask</a>. It’s also where you define what the <a href="../container/streams.html">input streams</a> are for your task.</li> <li>The serializers section defines the classes of the <a href="../container/serialization.html">serdes</a> used for serialization and deserialization of specific objects that are received and sent along different streams.</li> -<li>The system section defines systems that your StreamTask can read from along with the types of serdes used for sending keys and messages from that system. Usually, you’ll define a Kafka system, if you’re reading from Kafka, although you can also specify your own self-implemented Samza-compatible systems. See the <a href="/startup/hello-samza/latest">hello-samza example project</a>’s Wikipedia system for a good example of a self-implemented system.</li> +<li>The system section defines systems that your StreamTask can read from along with the types of serdes used for sending keys and messages from that system. Usually, you’ll define a Kafka system, if you’re reading from Kafka, although you can also specify your own self-implemented Samza-compatible systems. See the <a href="/startup/hello-samza/latest">hello-samza example project</a>‘s Wikipedia system for a good example of a self-implemented system.</li> </ol> <h3 id="required-configuration">Required Configuration</h3> @@ -193,7 +191,7 @@ that configuration keys prefixed with &l will be masked in logs and Samza’s YARN ApplicationMaster UI. This is to prevent accidental disclosure only; no encryption is done.</p> -<h2 id="packaging-»"><a href="packaging.html">Packaging »</a></h2> +<h2 id="packaging"><a href="packaging.html">Packaging »</a></h2> </div> @@ -211,7 +209,7 @@ encryption is done.</p> <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/configuration.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/configuration" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/jobs/job-runner.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/job-runner.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/job-runner.html (original) +++ samza/site/learn/documentation/latest/jobs/job-runner.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/jobs/job-runner.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/jobs/job-runner";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -149,21 +147,21 @@ <p>Samza jobs are started using a script called run-job.sh.</p> -<div class="highlight"><pre><code class="bash">samza-example/target/bin/run-job.sh <span class="se">\</span> +<figure class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>samza-example/target/bin/run-job.sh <span class="se">\</span> --config-factory<span class="o">=</span>org.apache.samza.config.factories.PropertiesConfigFactory <span class="se">\</span> - --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/config/hello-world.properties</code></pre></div> + --config-path<span class="o">=</span>file://<span class="nv">$PWD</span>/config/hello-world.properties</code></pre></figure> <p>You provide two parameters to the run-job.sh script. One is the config location, and the other is a factory class that is used to read your configuration file. The run-job.sh script is actually executing a Samza class called JobRunner. The JobRunner uses your ConfigFactory to get a Config object from the config path.</p> -<div class="highlight"><pre><code class="java"><span class="kd">public</span> <span class="kd">interface</span> <span class="nc">ConfigFactory</span> <span class="o">{</span> +<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="kd">public</span> <span class="kd">interface</span> <span class="nc">ConfigFactory</span> <span class="o">{</span> <span class="n">Config</span> <span class="nf">getConfig</span><span class="o">(</span><span class="n">URI</span> <span class="n">configUri</span><span class="o">);</span> -<span class="o">}</span></code></pre></div> +<span class="o">}</span></code></pre></figure> <p>The Config object is just a wrapper around Map<String, String>, with some nice helper methods. Out of the box, Samza ships with the PropertiesConfigFactory, but developers can implement any kind of ConfigFactory they wish.</p> <p>Once the JobRunner gets your configuration, it gives your configuration to the StreamJobFactory class defined by the “job.factory” property. Samza ships with three job factory implementations: ThreadJobFactory, ProcessJobFactory and YarnJobFactory. The StreamJobFactory’s responsibility is to give the JobRunner a job that it can run.</p> -<div class="highlight"><pre><code class="java"><span class="kd">public</span> <span class="kd">interface</span> <span class="nc">StreamJob</span> <span class="o">{</span> +<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span><span class="kd">public</span> <span class="kd">interface</span> <span class="nc">StreamJob</span> <span class="o">{</span> <span class="n">StreamJob</span> <span class="nf">submit</span><span class="o">();</span> <span class="n">StreamJob</span> <span class="nf">kill</span><span class="o">();</span> @@ -173,13 +171,13 @@ <span class="n">ApplicationStatus</span> <span class="nf">waitForStatus</span><span class="o">(</span><span class="n">ApplicationStatus</span> <span class="n">status</span><span class="o">,</span> <span class="kt">long</span> <span class="n">timeoutMs</span><span class="o">);</span> <span class="n">ApplicationStatus</span> <span class="nf">getStatus</span><span class="o">();</span> -<span class="o">}</span></code></pre></div> +<span class="o">}</span></code></pre></figure> <p>Once the JobRunner gets a job, it calls submit() on the job. This method is what tells the StreamJob implementation to start the SamzaContainer. In the case of LocalJobRunner, it uses a run-container.sh script to execute the SamzaContainer in a separate process, which will start one SamzaContainer locally on the machine that you ran run-job.sh on.</p> <p>This flow differs slightly when you use YARN, but we’ll get to that later.</p> -<h2 id="configuration-»"><a href="configuration.html">Configuration »</a></h2> +<h2 id="configuration"><a href="configuration.html">Configuration »</a></h2> </div> @@ -197,7 +195,7 @@ <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/job-runner.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/job-runner" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/jobs/logging.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/logging.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/logging.html (original) +++ samza/site/learn/documentation/latest/jobs/logging.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/jobs/logging.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/jobs/logging";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -153,12 +151,12 @@ <p>The <a href="/startup/hello-samza/latest">hello-samza</a> project shows how to use <a href="http://logging.apache.org/log4j/1.2/";>log4j</a> with Samza. To turn on log4j logging, you just need to make sure slf4j-log4j12 is in your SamzaContainer’s classpath. In Maven, this can be done by adding the following dependency to your Samza package project.</p> -<div class="highlight"><pre><code class="xml"><span class="nt"><dependency></span> +<figure class="highlight"><pre><code class="language-xml" data-lang="xml"><span></span><span class="nt"><dependency></span> <span class="nt"><groupId></span>org.slf4j<span class="nt"></groupId></span> <span class="nt"><artifactId></span>slf4j-log4j12<span class="nt"></artifactId></span> <span class="nt"><scope></span>runtime<span class="nt"></scope></span> <span class="nt"><version></span>1.6.2<span class="nt"></version></span> -<span class="nt"></dependency></span></code></pre></div> +<span class="nt"></dependency></span></code></pre></figure> <p>If you’re not using Maven, just make sure that slf4j-log4j12 ends up in your Samza package’s lib directory.</p> @@ -166,30 +164,30 @@ <p>Samza’s <a href="packaging.html">run-class.sh</a> script will automatically set the following setting if log4j.xml exists in your <a href="packaging.html">Samza package’s</a> lib directory.</p> -<div class="highlight"><pre><code class="bash">-Dlog4j.configuration<span class="o">=</span>file:<span class="nv">$base_dir</span>/lib/log4j.xml</code></pre></div> +<figure class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>-Dlog4j.configuration<span class="o">=</span>file:<span class="nv">$base_dir</span>/lib/log4j.xml</code></pre></figure> <p>The <a href="packaging.html">run-class.sh</a> script will also set the following Java system properties:</p> -<div class="highlight"><pre><code class="bash">-Dsamza.log.dir<span class="o">=</span><span class="nv">$SAMZA_LOG_DIR</span></code></pre></div> +<figure class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>-Dsamza.log.dir<span class="o">=</span><span class="nv">$SAMZA_LOG_DIR</span></code></pre></figure> <p>The <a href="packaging.html">run-container.sh</a> will also set:</p> -<div class="highlight"><pre><code class="bash">-Dsamza.container.id<span class="o">=</span><span class="nv">$SAMZA_CONTAINER_ID</span> -Dsamza.container.name<span class="o">=</span>samza-container-<span class="nv">$SAMZA_CONTAINER_ID</span><span class="err">"</span></code></pre></div> +<figure class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>-Dsamza.container.id<span class="o">=</span><span class="nv">$SAMZA_CONTAINER_ID</span> -Dsamza.container.name<span class="o">=</span>samza-container-<span class="nv">$SAMZA_CONTAINER_ID</span><span class="s2">"</span></code></pre></figure> <p>Likewise, <a href="packaging.html">run-am.sh</a> sets:</p> -<div class="highlight"><pre><code class="bash">-Dsamza.container.name<span class="o">=</span>samza-application-master</code></pre></div> +<figure class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>-Dsamza.container.name<span class="o">=</span>samza-application-master</code></pre></figure> <p>These settings are very useful if you’re using a file-based appender. For example, you can use a rolling appender to separate log file when it reaches certain size by configuring log4j.xml like this:</p> -<div class="highlight"><pre><code class="xml"><span class="nt"><appender</span> <span class="na">name=</span><span class="s">"RollingAppender"</span> <span class="na">class=</span><span class="s">"org.apache.log4j.RollingFileAppender"</span><span class="nt">></span> +<figure class="highlight"><pre><code class="language-xml" data-lang="xml"><span></span><span class="nt"><appender</span> <span class="na">name=</span><span class="s">"RollingAppender"</span> <span class="na">class=</span><span class="s">"org.apache.log4j.RollingFileAppender"</span><span class="nt">></span> <span class="nt"><param</span> <span class="na">name=</span><span class="s">"File"</span> <span class="na">value=</span><span class="s">"${samza.log.dir}/${samza.container.name}.log"</span> <span class="nt">/></span> <span class="nt"><param</span> <span class="na">name=</span><span class="s">"MaxFileSize"</span> <span class="na">value=</span><span class="s">"256MB"</span> <span class="nt">/></span> <span class="nt"><param</span> <span class="na">name=</span><span class="s">"MaxBackupIndex"</span> <span class="na">value=</span><span class="s">"20"</span> <span class="nt">/></span> <span class="nt"><layout</span> <span class="na">class=</span><span class="s">"org.apache.log4j.PatternLayout"</span><span class="nt">></span> <span class="nt"><param</span> <span class="na">name=</span><span class="s">"ConversionPattern"</span> <span class="na">value=</span><span class="s">"%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %c{1} [%p] %m%n"</span> <span class="nt">/></span> <span class="nt"></layout></span> -<span class="nt"></appender></span></code></pre></div> +<span class="nt"></appender></span></code></pre></figure> <p>Setting up a file-based appender is recommended as a better alternative to using standard out. Standard out log files (see below) don’t roll, and can get quite large if used for logging.</p> @@ -197,7 +195,7 @@ <p>When using a rolling file appender, it is common for a long-running job to exceed the max file size and count. In such cases, the beginning of the logs will be lost. Since the beginning of the logs include some of the most critical information like configuration, it is important to not lose this information. To address this issue, Samza logs this critical information to a “startup logger” in addition to the normal logger. You can write these log messages to a separate, finite file by including the following snippet in your log4j.xml: </p> -<div class="highlight"><pre><code class="xml"><span class="nt"><appender</span> <span class="na">name=</span><span class="s">"StartupAppender"</span> <span class="na">class=</span><span class="s">"org.apache.log4j.RollingFileAppender"</span><span class="nt">></span> +<figure class="highlight"><pre><code class="language-xml" data-lang="xml"><span></span><span class="nt"><appender</span> <span class="na">name=</span><span class="s">"StartupAppender"</span> <span class="na">class=</span><span class="s">"org.apache.log4j.RollingFileAppender"</span><span class="nt">></span> <span class="nt"><param</span> <span class="na">name=</span><span class="s">"File"</span> <span class="na">value=</span><span class="s">"${samza.log.dir}/${samza.container.name}-startup.log"</span> <span class="nt">/></span> <span class="nt"><param</span> <span class="na">name=</span><span class="s">"MaxFileSize"</span> <span class="na">value=</span><span class="s">"256MB"</span> <span class="nt">/></span> <span class="nt"><param</span> <span class="na">name=</span><span class="s">"MaxBackupIndex"</span> <span class="na">value=</span><span class="s">"1"</span> <span class="nt">/></span> @@ -208,42 +206,42 @@ <span class="nt"><logger</span> <span class="na">name=</span><span class="s">"STARTUP_LOGGER"</span> <span class="na">additivity=</span><span class="s">"false"</span><span class="nt">></span> <span class="nt"><level</span> <span class="na">value=</span><span class="s">"info"</span> <span class="nt">/></span> <span class="nt"><appender-ref</span> <span class="na">ref=</span><span class="s">"StartupAppender"</span><span class="nt">/></span> -<span class="nt"></logger></span></code></pre></div> +<span class="nt"></logger></span></code></pre></figure> <h4 id="changing-log-levels">Changing log levels</h4> <p>Sometimes it’s desirable to change the Log4J log level from <code>INFO</code> to <code>DEBUG</code> at runtime so that a developer can enable more logging for a Samza container that’s exhibiting undesirable behavior. Samza provides a Log4j class called JmxAppender, which will allow you to dynamically modify log levels at runtime. The JmxAppender class is located in the samza-log4j package, and can be turned on by first adding a runtime dependency to the samza-log4j package:</p> -<div class="highlight"><pre><code class="xml"><span class="nt"><dependency></span> +<figure class="highlight"><pre><code class="language-xml" data-lang="xml"><span></span><span class="nt"><dependency></span> <span class="nt"><groupId></span>org.apache.samza<span class="nt"></groupId></span> <span class="nt"><artifactId></span>samza-log4j<span class="nt"></artifactId></span> <span class="nt"><scope></span>runtime<span class="nt"></scope></span> <span class="nt"><version></span>${samza.version}<span class="nt"></version></span> -<span class="nt"></dependency></span></code></pre></div> +<span class="nt"></dependency></span></code></pre></figure> <p>And then updating your log4j.xml to include the appender:</p> -<div class="highlight"><pre><code class="xml"><span class="nt"><appender</span> <span class="na">name=</span><span class="s">"jmx"</span> <span class="na">class=</span><span class="s">"org.apache.samza.logging.log4j.JmxAppender"</span> <span class="nt">/></span></code></pre></div> +<figure class="highlight"><pre><code class="language-xml" data-lang="xml"><span></span><span class="nt"><appender</span> <span class="na">name=</span><span class="s">"jmx"</span> <span class="na">class=</span><span class="s">"org.apache.samza.logging.log4j.JmxAppender"</span> <span class="nt">/></span></code></pre></figure> <h4 id="stream-log4j-appender">Stream Log4j Appender</h4> -<p>Samza provides a StreamAppender to publish the logs into a specific system. You can specify the system name using “task.log4j.system” and change name of log stream with param ‘StreamName’. Also, we have the <a href="http://logback.qos.ch/manual/mdc.html";>MDC</a> keys “containerName”, “jobName” and “jobId”, which help identify the source of the log. In order to use this appender, simply add:</p> +<p>Samza provides a StreamAppender to publish the logs into a specific system. You can specify the system name using “task.log4j.system” and change name of log stream with param ‘StreamName’. The <a href="http://logback.qos.ch/manual/mdc.html";>MDC</a> contains the keys “containerName”, “jobName” and “jobId”, which help identify the source of the log. In order to use this appender, add:</p> -<div class="highlight"><pre><code class="xml"><span class="nt"><appender</span> <span class="na">name=</span><span class="s">"StreamAppender"</span> <span class="na">class=</span><span class="s">"org.apache.samza.logging.log4j.StreamAppender"</span><span class="nt">></span> +<figure class="highlight"><pre><code class="language-xml" data-lang="xml"><span></span><span class="nt"><appender</span> <span class="na">name=</span><span class="s">"StreamAppender"</span> <span class="na">class=</span><span class="s">"org.apache.samza.logging.log4j.StreamAppender"</span><span class="nt">></span> <span class="c"><!-- optional --></span> <span class="nt"><param</span> <span class="na">name=</span><span class="s">"StreamName"</span> <span class="na">value=</span><span class="s">"EpicStreamName"</span><span class="nt">/></span> <span class="nt"><layout</span> <span class="na">class=</span><span class="s">"org.apache.log4j.PatternLayout"</span><span class="nt">></span> <span class="nt"><param</span> <span class="na">name=</span><span class="s">"ConversionPattern"</span> <span class="na">value=</span><span class="s">"%X{containerName} %X{jobName} %X{jobId} %d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %c{1} [%p] %m%n"</span> <span class="nt">/></span> <span class="nt"></layout></span> -<span class="nt"></appender></span></code></pre></div> +<span class="nt"></appender></span></code></pre></figure> <p>and</p> -<div class="highlight"><pre><code class="xml"><span class="nt"><appender-ref</span> <span class="na">ref=</span><span class="s">"StreamAppender"</span><span class="nt">/></span></code></pre></div> +<figure class="highlight"><pre><code class="language-xml" data-lang="xml"><span></span><span class="nt"><appender-ref</span> <span class="na">ref=</span><span class="s">"StreamAppender"</span><span class="nt">/></span></code></pre></figure> <p>to log4j.xml and define the system name by specifying the config:</p> -<div class="highlight"><pre><code class="xml">task.log4j.system="<span class="nt"><system-name></span>"</code></pre></div> +<figure class="highlight"><pre><code class="language-xml" data-lang="xml"><span></span>task.log4j.system="<span class="nt"><system-name></span>"</code></pre></figure> <p>The default stream name for logger is generated using the following convention, though you can override it using the <code>StreamName</code> property in the log4j.xml as shown above. <code>java @@ -252,8 +250,8 @@ <p>Configuring the StreamAppender will automatically encode messages using logstash’s <a href="https://github.com/logstash/log4j-jsonevent-layout";>Log4J JSON format</a>. Samza also supports pluggable serialization for those that prefer non-JSON logging events. This can be configured the same way other stream serializers are defined:</p> -<div class="highlight"><pre><code class="jproperties"><span class="na">serializers.registry.log4j-string.class</span><span class="o">=</span><span class="s">org.apache.samza.logging.log4j.serializers.LoggingEventStringSerdeFactory</span> -<span class="na">systems.mock.streams.__samza_jobname_jobid_logs.samza.msg.serde</span><span class="o">=</span><span class="s">log4j-string</span></code></pre></div> +<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">serializers.registry.log4j-string.class</span><span class="o">=</span><span class="s">org.apache.samza.logging.log4j.serializers.LoggingEventStringSerdeFactory</span> +<span class="na">systems.mock.streams.__samza_jobname_jobid_logs.samza.msg.serde</span><span class="o">=</span><span class="s">log4j-string</span></code></pre></figure> <p>The StreamAppender will always send messages to a job’s log stream keyed by the container name.</p> @@ -265,13 +263,13 @@ <p>Samza will automatically set the following garbage collection logging setting, and will output it to <code>$SAMZA_LOG_DIR/gc.log</code>.</p> -<div class="highlight"><pre><code class="bash">-XX:+PrintGCDateStamps -Xloggc:<span class="nv">$SAMZA_LOG_DIR</span>/gc.log</code></pre></div> +<figure class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>-XX:+PrintGCDateStamps -Xloggc:<span class="nv">$SAMZA_LOG_DIR</span>/gc.log</code></pre></figure> <h4 id="rotation">Rotation</h4> <p>In older versions of Java, it is impossible to have GC logs roll over based on time or size without the use of a secondary tool. This means that your GC logs will never be deleted until a Samza job ceases to run. As of <a href="http://www.oracle.com/technetwork/java/javase/2col/6u34-bugfixes-1733379.html";>Java 6 Update 34</a>, and <a href="http://www.oracle.com/technetwork/java/javase/7u2-relnotes-1394228.html";>Java 7 Update 2</a>, <a href="http://bugs.sun.com/bugdatabase/view_bug.do?bug_id=6941923";>new GC command line switches</a> have been added to support this functionality. If GC log file rotation is supported by the JVM, Samza will also set:</p> -<div class="highlight"><pre><code class="bash">-XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles<span class="o">=</span>10 -XX:GCLogFileSize<span class="o">=</span>10241024</code></pre></div> +<figure class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span>-XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles<span class="o">=</span><span class="m">10</span> -XX:GCLogFileSize<span class="o">=</span><span class="m">10241024</span></code></pre></figure> <h3 id="yarn">YARN</h3> @@ -281,7 +279,7 @@ <p>Samza’s <a href="../yarn/application-master.html">ApplicationMaster</a> pipes all STDOUT and STDERR output to logs/stdout and logs/stderr, respectively. These files are never rotated.</p> -<h2 id="reprocessing-»"><a href="reprocessing.html">Reprocessing »</a></h2> +<h2 id="reprocessing"><a href="reprocessing.html">Reprocessing »</a></h2> </div> @@ -299,7 +297,7 @@ <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/logging.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/logging" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/jobs/packaging.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/packaging.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/packaging.html (original) +++ samza/site/learn/documentation/latest/jobs/packaging.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/jobs/packaging.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/jobs/packaging";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -148,13 +146,13 @@ --> <p>The <a href="job-runner.html">JobRunner</a> page talks about run-job.sh, and how it’s used to start a job either locally (ProcessJobFactory/ThreadJobFactory) or with YARN (YarnJobFactory). In the diagram that shows the execution flow, it also shows a run-container.sh script. This script, along with a run-am.sh script, are what Samza actually calls to execute its code.</p> -<div class="highlight"><pre><code class="language-text" data-lang="text">bin/run-am.sh +<div class="highlight"><pre><code class="language-text" data-lang="text"><span></span>bin/run-am.sh bin/run-container.sh </code></pre></div> <p>The run-container.sh script is responsible for starting the <a href="../container/samza-container.html">SamzaContainer</a>. The run-am.sh script is responsible for starting Samza’s application master for YARN. Thus, the run-am.sh script is only used by the YarnJob, but both YarnJob and ProcessJob use run-container.sh.</p> <p>Typically, these two scripts are bundled into a tar.gz file that has a structure like this:</p> -<div class="highlight"><pre><code class="language-text" data-lang="text">bin/run-am.sh +<div class="highlight"><pre><code class="language-text" data-lang="text"><span></span>bin/run-am.sh bin/run-class.sh bin/run-job.sh bin/run-container.sh @@ -166,7 +164,7 @@ lib/*.jar <p>The second statement, that your Samza package contains all JARs that it needs to run, means that a Samza package is entirely self contained. This allows Samza jobs to run on independent Samza versions without conflicting with each other. This is in contrast to Hadoop, where JARs are pulled in from the local machine that the job is running on (using environment variables). With Samza, you might run your job on version 0.7.0, and someone else might run their job on version 0.8.0. There is no problem with this.</p> -<h2 id="yarn-jobs-»"><a href="yarn-jobs.html">YARN Jobs »</a></h2> +<h2 id="yarn-jobs"><a href="yarn-jobs.html">YARN Jobs »</a></h2> </div> @@ -184,7 +182,7 @@ lib/*.jar <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/packaging.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/packaging" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/jobs/reprocessing.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/reprocessing.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/reprocessing.html (original) +++ samza/site/learn/documentation/latest/jobs/reprocessing.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/jobs/reprocessing.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/jobs/reprocessing";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -217,7 +215,7 @@ <p>Samza gives you a lot of flexibility for reprocessing historical data, and you don’t need to program against a separate batch processing API to take advantage of it. If you’re mindful of these issues, you can build a data system that is very robust, but still gives you lots of freedom to change your processing logic in future.</p> -<h2 id="web-ui-and-rest-api-»"><a href="web-ui-rest-api.html">Web UI and REST API »</a></h2> +<h2 id="web-ui-and-rest-api"><a href="web-ui-rest-api.html">Web UI and REST API »</a></h2> </div> @@ -235,7 +233,7 @@ <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/reprocessing.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/reprocessing" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/jobs/split-deployment.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/split-deployment.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/split-deployment.html (original) +++ samza/site/learn/documentation/latest/jobs/split-deployment.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/jobs/split-deployment.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/jobs/split-deployment";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -189,12 +187,12 @@ required in organizations that run tens The Samza framework package should be deployed to ALL the machines of a cluster into a predefined, fixed location. This could be done by merely copying the jars, or creating a meta package that would deploy all of them. Let’s assume that ‘samza-framework’ package is installed into the ‘/…/samza-fwk/0.12.0’ directory.</p></li> <li><p><strong>Create symbolic link</strong>: A symbolic link needs to be created for the <strong>stable</strong> version of the framework to point to the framework location, e.g.: -<div class="highlight"><pre><code class="bash">ln -s /.../samza-fwk/0.12.0 /.../samza-fwk/STABLE<span class="err">'</span></code></pre></div></p></li> +<figure class="highlight"><pre><code class="language-bash" data-lang="bash"><span></span> ln -s /.../samza-fwk/0.12.0 /.../samza-fwk/STABLE<span class="err">'</span> </code></pre></figure></p></li> <li><p><strong>Deploy user job</strong>: In the job’s config, the following property is required to enable split deployment, e.g. for Samza framework path at ‘/…/samza-fwk’: -<div class="highlight"><pre><code class="jproperties"><span class="na">samza.fwk.path</span><span class="o">=</span><span class="s">/.../samza-fwk</span></code></pre></div> +<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na"> samza.fwk.path</span><span class="o">=</span><span class="s">/.../samza-fwk </span></code></pre></figure> By default Samza will look for the <strong>stable</strong> link inside the folder to find the framework. You can also override the version by configuring: -<div class="highlight"><pre><code class="jproperties"><span class="na">samza.fwk.version</span><span class="o">=</span><span class="s">0.11.1</span></code></pre></div> +<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na"> samza.fwk.version</span><span class="o">=</span><span class="s">0.11.1 </span></code></pre></figure> In this case Samza will pick ‘/…/samza-fwk/0.11.1’ as the framework location. This way users can perform canary, upgrade and rollback their jobs easily by changing version in the config.</p></li> </ol> @@ -214,7 +212,7 @@ In this case Samza will pick ‘/&he <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/split-deployment.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/split-deployment" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/jobs/web-ui-rest-api.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/web-ui-rest-api.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/web-ui-rest-api.html (original) +++ samza/site/learn/documentation/latest/jobs/web-ui-rest-api.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/jobs/web-ui-rest-api.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/jobs/web-ui-rest-api";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -189,7 +187,7 @@ </tbody> </table> -<h2 id="application-master-»"><a href="../yarn/application-master.html">Application Master »</a></h2> +<h2 id="application-master"><a href="../yarn/application-master.html">Application Master »</a></h2> </div> @@ -207,7 +205,7 @@ <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/web-ui-rest-api.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/web-ui-rest-api" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/jobs/yarn-jobs.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/yarn-jobs.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/yarn-jobs.html (original) +++ samza/site/learn/documentation/latest/jobs/yarn-jobs.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/jobs/yarn-jobs.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/jobs/yarn-jobs";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -151,19 +149,19 @@ <p>If you want to use YARN to run your Samza job, you’ll also need to define the location of your Samza job’s package. For example, you might say:</p> -<div class="highlight"><pre><code class="jproperties"><span class="na">yarn.package.path</span><span class="o">=</span><span class="s">http://my.http.server/jobs/ingraphs-package-0.0.55.tgz</span></code></pre></div> +<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">yarn.package.path</span><span class="o">=</span><span class="s">http://my.http.server/jobs/ingraphs-package-0.0.55.tgz</span></code></pre></figure> <p>This .tgz file follows the conventions outlined on the <a href="packaging.html">Packaging</a> page (it has bin/run-am.sh and bin/run-container.sh). YARN NodeManagers will take responsibility for downloading this .tgz file on the appropriate machines, and untar'ing them. From there, YARN will execute run-am.sh or run-container.sh for the Samza Application Master, and SamzaContainer, respectively.</p> <p>If you want to run Samza job in the specific YARN queue not the default one, you can set <code>yarn.queue</code> property in your job’s configuration. For example, with the following property setting,</p> -<div class="highlight"><pre><code class="jproperties"><span class="na">yarn.queue</span><span class="o">=</span><span class="s">root.adhoc</span></code></pre></div> +<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">yarn.queue</span><span class="o">=</span><span class="s">root.adhoc</span></code></pre></figure> <p>Samza job will run in the root.adhoc queue.</p> <!-- TODO document job.container.count and other key configs --> -<h2 id="logging-»"><a href="logging.html">Logging »</a></h2> +<h2 id="logging"><a href="logging.html">Logging »</a></h2> </div> @@ -181,7 +179,7 @@ <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/yarn-jobs.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/jobs/yarn-jobs" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/operations/kafka.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/operations/kafka.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/operations/kafka.html (original) +++ samza/site/learn/documentation/latest/operations/kafka.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/operations/kafka.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/operations/kafka";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -157,7 +155,7 @@ <p>Kafka brokers should be configured to automatically create topics. Without this, it’s going to be very cumbersome to run Samze jobs, since jobs will write to arbitrary (and sometimes new) topics.</p> -<div class="highlight"><pre><code class="jproperties"><span class="na">auto.create.topics.enable</span><span class="o">=</span><span class="s">true</span></code></pre></div> +<figure class="highlight"><pre><code class="language-jproperties" data-lang="jproperties"><span></span><span class="na">auto.create.topics.enable</span><span class="o">=</span><span class="s">true</span></code></pre></figure> </div> @@ -175,7 +173,7 @@ <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/operations/kafka.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/operations/kafka" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/operations/security.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/operations/security.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/operations/security.html (original) +++ samza/site/learn/documentation/latest/operations/security.html Fri May 25 22:28:38 2018 @@ -44,9 +44,7 @@ <!-- this icon only shows in versioned pages --> - - - <a href="http://samza.apache.org/learn/documentation/0.14/operations/security.html";><i id="switch-version-button"></i></a> + <a href="http://samza.apache.org/learn/documentation/0.14/operations/security";><i id="switch-version-button"></i></a> <!-- links for the navigation bar --> @@ -157,7 +155,7 @@ <p>Kafka provides no security for its topics, and therefore Samza doesn’t provide any security when using Kafka topics.</p> -<h3 id="securing-samza's-environment">Securing Samza’s Environment</h3> +<h3 id="securing-samzas-environment">Securing Samza’s Environment</h3> <p>The most important thing to keep in mind when securing an environment that Samza containers run in is that <strong>Samza containers execute arbitrary user code</strong>. They must considered an adversarial application, and the environment must be locked down accordingly.</p> @@ -199,7 +197,7 @@ <p>Samza provides out-of-the-box YARN integration. Take a look at Samza’s YARN Security page for details.</p> -<h2 id="kafka-»"><a href="kafka.html">Kafka »</a></h2> +<h2 id="kafka"><a href="kafka.html">Kafka »</a></h2> </div> @@ -217,7 +215,7 @@ <script> $( document ).ready(function() { - if ( $.fn.urlExists( "/learn/documentation/0.14/operations/security.html" ) ) { + if ( $.fn.urlExists( "/learn/documentation/0.14/operations/security" ) ) { $("#switch-version-button").addClass("fa fa-history masthead-icon"); } }); Modified: samza/site/learn/documentation/latest/rest/javadocs/allclasses-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/allclasses-frame.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/allclasses-frame.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/allclasses-frame.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:34 PST 2018 --> -<title>All Classes (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>All Classes (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> Modified: samza/site/learn/documentation/latest/rest/javadocs/allclasses-noframe.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/allclasses-noframe.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/allclasses-noframe.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/allclasses-noframe.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:34 PST 2018 --> -<title>All Classes (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>All Classes (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> Modified: samza/site/learn/documentation/latest/rest/javadocs/constant-values.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/constant-values.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/constant-values.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/constant-values.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:34 PST 2018 --> -<title>Constant Field Values (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>Constant Field Values (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="Constant Field Values (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="Constant Field Values (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/deprecated-list.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/deprecated-list.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/deprecated-list.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/deprecated-list.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:34 PST 2018 --> -<title>Deprecated List (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>Deprecated List (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="Deprecated List (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="Deprecated List (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/help-doc.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/help-doc.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/help-doc.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/help-doc.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:34 PST 2018 --> -<title>API Help (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>API Help (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="API Help (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="API Help (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/index-all.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/index-all.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/index-all.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/index-all.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:34 PST 2018 --> -<title>Index (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>Index (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="Index (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="Index (samza-rest 0.14.1 API)"; } } catch(err) { @@ -336,6 +336,8 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/monitor/MonitorConfig.html#getSchedulingIntervalInMs--">getSchedulingIntervalInMs()</a></span> - Method in class org.apache.samza.monitor.<a href="org/apache/samza/monitor/MonitorConfig.html" title="class in org.apache.samza.monitor">MonitorConfig</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/monitor/MonitorConfig.html#getSchedulingJitterPercent--">getSchedulingJitterPercent()</a></span> - Method in class org.apache.samza.monitor.<a href="org/apache/samza/monitor/MonitorConfig.html" title="class in org.apache.samza.monitor">MonitorConfig</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/rest/proxy/installation/InstallationRecord.html#getScriptFilePath--">getScriptFilePath()</a></span> - Method in class org.apache.samza.rest.proxy.installation.<a href="org/apache/samza/rest/proxy/installation/InstallationRecord.html" title="class in org.apache.samza.rest.proxy.installation">InstallationRecord</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/rest/proxy/job/ScriptJobProxy.html#getScriptPath-org.apache.samza.rest.proxy.job.JobInstance-java.lang.String-">getScriptPath(JobInstance, String)</a></span> - Method in class org.apache.samza.rest.proxy.job.<a href="org/apache/samza/rest/proxy/job/ScriptJobProxy.html" title="class in org.apache.samza.rest.proxy.job">ScriptJobProxy</a></dt> Modified: samza/site/learn/documentation/latest/rest/javadocs/index.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/index.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/index.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/index.html Fri May 25 22:28:38 2018 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:34 PST 2018 --> -<title>samza-rest 0.14.1-SNAPSHOT API</title> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>samza-rest 0.14.1 API</title> <script type="text/javascript"> tmpTargetPage = "" + window.location.search; if (tmpTargetPage != "" && tmpTargetPage != "undefined") Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/JobsClient.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/JobsClient.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/JobsClient.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/JobsClient.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>JobsClient (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>JobsClient (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="JobsClient (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="JobsClient (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitor.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitor.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitor.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitor.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>LocalStoreMonitor (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>LocalStoreMonitor (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="LocalStoreMonitor (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="LocalStoreMonitor (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorConfig.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorConfig.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorConfig.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorConfig.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>LocalStoreMonitorConfig (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>LocalStoreMonitorConfig (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="LocalStoreMonitorConfig (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="LocalStoreMonitorConfig (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorFactory.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorFactory.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorFactory.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorFactory.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>LocalStoreMonitorFactory (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>LocalStoreMonitorFactory (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="LocalStoreMonitorFactory (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="LocalStoreMonitorFactory (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorMetrics.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorMetrics.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorMetrics.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/LocalStoreMonitorMetrics.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>LocalStoreMonitorMetrics (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>LocalStoreMonitorMetrics (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="LocalStoreMonitorMetrics (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="LocalStoreMonitorMetrics (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/Monitor.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/Monitor.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/Monitor.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/Monitor.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>Monitor (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>Monitor (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="Monitor (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="Monitor (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorConfig.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorConfig.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorConfig.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorConfig.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>MonitorConfig (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>MonitorConfig (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,13 +12,13 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="MonitorConfig (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="MonitorConfig (samza-rest 0.14.1 API)"; } } catch(err) { } //--> -var methods = {"i0":9,"i1":10,"i2":10}; +var methods = {"i0":9,"i1":10,"i2":10,"i3":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -219,6 +219,10 @@ extends org.apache.samza.config.MapConfi <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/monitor/MonitorConfig.html#getSchedulingIntervalInMs--">getSchedulingIntervalInMs</a></span>()</code> </td> </tr> +<tr id="i3" class="rowColor"> +<td class="colFirst"><code>double</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/monitor/MonitorConfig.html#getSchedulingJitterPercent--">getSchedulingJitterPercent</a></span>()</code> </td> +</tr> </table> <ul class="blockList"> <li class="blockList"><a name="methods.inherited.from.class.org.apache.samza.config.MapConfig"> @@ -347,7 +351,7 @@ extends org.apache.samza.config.MapConfi <a name="getSchedulingIntervalInMs--"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>getSchedulingIntervalInMs</h4> <pre>public int getSchedulingIntervalInMs()</pre> @@ -358,6 +362,15 @@ extends org.apache.samza.config.MapConfi </dl> </li> </ul> +<a name="getSchedulingJitterPercent--"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>getSchedulingJitterPercent</h4> +<pre>public double getSchedulingJitterPercent()</pre> +</li> +</ul> </li> </ul> </li> Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorFactory.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorFactory.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorFactory.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorFactory.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>MonitorFactory (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>MonitorFactory (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="MonitorFactory (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="MonitorFactory (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorLoader.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorLoader.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorLoader.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/MonitorLoader.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>MonitorLoader (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>MonitorLoader (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="MonitorLoader (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="MonitorLoader (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SamzaMonitorService.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SamzaMonitorService.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SamzaMonitorService.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SamzaMonitorService.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>SamzaMonitorService (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>SamzaMonitorService (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SamzaMonitorService (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="SamzaMonitorService (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/ScheduledExecutorSchedulingProvider.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/ScheduledExecutorSchedulingProvider.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/ScheduledExecutorSchedulingProvider.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/ScheduledExecutorSchedulingProvider.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>ScheduledExecutorSchedulingProvider (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>ScheduledExecutorSchedulingProvider (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="ScheduledExecutorSchedulingProvider (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="ScheduledExecutorSchedulingProvider (samza-rest 0.14.1 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SchedulingProvider.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SchedulingProvider.html?rev=1832281&r1=1832280&r2=1832281&view=diff ============================================================================== --- samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SchedulingProvider.html (original) +++ samza/site/learn/documentation/latest/rest/javadocs/org/apache/samza/monitor/SchedulingProvider.html Fri May 25 22:28:38 2018 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Thu Jan 04 10:03:33 PST 2018 --> -<title>SchedulingProvider (samza-rest 0.14.1-SNAPSHOT API)</title> -<meta name="date" content="2018-01-04"> +<!-- Generated by javadoc (1.8.0_121) on Fri May 25 15:22:13 PDT 2018 --> +<title>SchedulingProvider (samza-rest 0.14.1 API)</title> +<meta name="date" content="2018-05-25"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SchedulingProvider (samza-rest 0.14.1-SNAPSHOT API)"; + parent.document.title="SchedulingProvider (samza-rest 0.14.1 API)"; } } catch(err) {
