Details on Checkpointing if there are multiple/different sources grouped together.

[anaray]

Hi,

Please help me to understand checkpointing if there multiple/different
sources and which is grouped together.

                       |                                                                  
|--------------------|
KAFKA TOPIC 1 |  ----  SOURCE1(DataStream1) ---------------- |                        
|
                       |                                                                  
| COGROUP          |------------ SINK
                       |                                                                  
|                         |
KAFKA TOPIC 2 |  ----- SOURCE2(DataStream2) ----------------
|-------------------|                          
                       |
(Kafka)                       (Flink)


I assume that in above case Source1 and Source2 will emit its own
independent checkpoint barriers (say at interval 1 min), and if so  will
there be 2 different snapshots of at COGROUP?


Thank You,



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/