One thing aboved comment should be adapted: > // ==> There should never be a case where we have no pending > transaction here
Btw @StefanRRichter are you sure that subsuming can happen as in this test that you added? Basing on this large comment (@StephanEwen written it for pravega connector), subsuming of notification should happen on JobManager and such subsumed notification shouldn't reach the task. [ Full content available at: https://github.com/apache/flink/pull/6723 ] This message was relayed via gitbox.apache.org for [email protected]
