flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rinat <r.shari...@cleverdata.ru>
Subject Flink send checkpointing message in IT
Date Mon, 30 Oct 2017 15:01:22 GMT
Hi guys, I’ve got a question about working with checkpointing. 
I would like to implement IT test, where source is a fixed collection of items and sink performs
additional logic, when checkpointing is completed.

I would like to force executing checkpointing, when all messages from my test source were
sent and processed by sink.
Please tell me, whether such logic could be performed or not, and how.

Thx !
View raw message