apache

/

flink

branch iconmaster

arrow to build time
clock icon35 hrs, 44 mins, 16 secs

Roman Khachatryan avatarRoman Khachatryan

[FLINK-12484][runtime] push checkpoint lock from StreamTask to SourceStream

Intermediate tasks (not source/sink) don't acquire lock anymore
(as they use single-threaded model).
SourceStreamTask still has to have the lock to conform to the public API.
MockStreamTask has the lock for compatibility with the existing tests.

Reply via email to