MINOR: Update TupleForwarder comment (apache#4414)

Reviewers: Guozhang Wang <wangguoz@gmail.com>
dtn97 · Feb 8, 2018 · e7905fc · e7905fc
1 parent 6780338
commit e7905fc
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java
@@ -23,7 +23,8 @@
 
 /**
  * This class is used to determine if a processor should forward values to child nodes.
- * Forwarding only occurs when caching is not enabled.
+ * Forwarding by this class only occurs when caching is not enabled. If caching is enabled,
+ * forwarding occurs in the flush listener when the cached store flushes.
  *
  * @param <K>
  * @param <V>