branch iconmaster

arrow to build time
clock icon1 hour, 58 mins, 46 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