flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bowenli86 <...@git.apache.org>
Subject [GitHub] flink pull request #6066: [FLINK-9428] [checkpointing] Allow operators to fl...
Date Wed, 23 May 2018 17:53:47 GMT
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 ...."


---

Mime
View raw message