Thanks,Xiangyu.
As you suggested,I've read the comments from 'ExternallyInducedSource.java' and
also taken a look into the source code of The legacy source of Pravega Flink
connector,I've figured it out now.
much appreciated.
-- --
??:
Hi Zhuliang,
I would suggest u reading the comments from
'ExternallyInducedSource.java'[1].
"Sources that implement this interface do not trigger checkpoints when
receiving a
trigger message from the checkpoint coordinator, but when their input
data/events
indicate that a checkpoint should be tri
Could any one tell me what the purpose and Philosophy of designing flink
checkpoint master hook?
Thanks.
