You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by fhueske <gi...@git.apache.org> on 2018/04/24 12:33:39 UTC
[GitHub] flink pull request #5887: [FLINK-6719] [docs] Add details about fault-tolera...
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5887#discussion_r183710783
--- Diff: docs/dev/stream/operators/process_function.md ---
@@ -271,9 +271,9 @@ override def onTimer(timestamp: Long, ctx: OnTimerContext, out: Collector[OUT]):
</div>
</div>
-## Optimizations
+## Timers
-### Timer Coalescing
+### Optimizations - Timer Coalescing
Every timer registered at the `TimerService` via `registerEventTimeTimer()` or
--- End diff --
Also it would be great if you could find a good spot to add a note that calls to `processElement()` and `onTimer()` are always synchronized, i.e., users do not have to worry about concurrent modification of state.
---