samza git commit: Minor: Re-word a couple of lines in javadoc with explicit notes about failures

[ja...@apache.org]

Repository: samza
Updated Branches:
  refs/heads/master 5eb470c02 -> 601c11d87


Minor: Re-word a couple of lines in javadoc with explicit notes about failures


Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/601c11d8
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/601c11d8
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/601c11d8

Branch: refs/heads/master
Commit: 601c11d873e3316aea538f2e0c51ac4a3c1648e7
Parents: 5eb470c
Author: vjagadish1989 <jv...@linkedin.com>
Authored: Wed May 10 12:03:53 2017 -0700
Committer: vjagadish1989 <jv...@linkedin.com>
Committed: Wed May 10 12:03:53 2017 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/samza/operators/MessageStream.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/samza/blob/601c11d8/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
----------------------------------------------------------------------
diff --git a/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java b/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
index 7e7a537..6d5b784 100644
--- a/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
+++ b/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
@@ -104,7 +104,7 @@ public interface MessageStream<M> {
    * <p>
    * Use the {@link org.apache.samza.operators.windows.Windows} helper methods to create the appropriate windows.
    * <p>
-   * <b>Note:</b> As of version 0.13.0, messages in windows are kept in memory and may be lost in case of failures.
+   * <b>Note:</b> As of version 0.13.0, messages in windows are kept in memory and will be lost during restarts.
    *
    * @param window the window to group and process messages from this {@link MessageStream}
    * @param <K> the type of key in the message in this {@link MessageStream}. If a key is specified,
@@ -121,7 +121,7 @@ public interface MessageStream<M> {
    * Messages in each stream are retained for the provided {@code ttl} and join results are
    * emitted as matches are found.
    * <p>
-   * <b>Note:</b> As of version 0.13.0, messages in joins are kept in memory and may be lost in case of failures.
+   * <b>Note:</b> As of version 0.13.0, messages in joins are kept in memory and will be lost during restarts.
    *
    * @param otherStream the other {@link MessageStream} to be joined with
    * @param joinFn the function to join messages from this and the other {@link MessageStream}