Thank you for the pointers and the clarification!
One question, when you say: "There is currently no way to be explicitly
notified about an incoming barrier”, isn’t `snapshotOperatorState` invoked when
a barrier approaches the operator?
Lorenzo Affetti
---
MD in computer engineerin
while I’m performing that asynchronous job.
Is the only way to use your code in master and send a DeclineCheckpoint message?
Thank you,
Lorenzo Affetti
On 11 Nov 2016, at 19:33, Stephan Ewen
mailto:se...@apache.org>> wrote:
What do you mean exactly with aborting a checkpoint? Continui
Hi everybody, I am using Flink v1.1.2
is it possible to programmatically abort a snapshot from the method
public StreamTaskState snapshotOperatorState(long checkpointId, long
timestamp)
In an operator?
Thank you!
Lorenzo
operators/Output.java>
:
A watermark specifies that no element with a timestamp *older or equal* to
the watermark timestamp will be emitted in the future.
I think that the documentation should be fixed to match "lower or equal to"
because it is what the system really does, I think.
Thank you
--
Lorenzo Affetti
