Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6066#discussion_r190342404
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java
---
@@ -93,6 +93,20 @@
// state snapshots
//
------------------------------------------------------------------------
+ /**
--- End diff --
This description feels like it states well what it's not intended for, but
doesn't clearly describe what it's intended for.
It would be great if you can add what you wrote in the ticket description
here, as of "Some operators maintain some small transient state ... Rather
that persisting that state in a checkpoint, it can make sense to flush the data
downstream ...."
---
