apache
/
flink
|
master
|
35 hrs, 44 mins, 16 secs
|
Roman 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.
|
|