Hi Amara,
please refer to [1] for some details about our checkpointing mechanism, in
short, for your situation:
* checkpoints are made at certain checkpoint barriers,
* in between those barriers, processing continues and so do outputs
* in case of a failure the state at the latest checkpoint is r
-Checkpoints-in-a-Flink-Highly-Available-cluster-tp13301p13483.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
Kafka) | | | |
|
|--| |---|
||
Thanks,
Amara
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Duplicated-data-when-using-Externalized-Checkpoints-in-a-Flink-Highly-Available-cluster-tp13301p13481.html
Sen
processing for my application? Could you
> please guide me on what I might have missed?
>
> Thanks,
> Amara
>
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Duplicated-data-
> when-using-Externalized
? Could you
please guide me on what I might have missed?
Thanks,
Amara
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Duplicated-data-when-using-Externalized-Checkpoints-in-a-Flink-Highly-Available-cluster-tp13301p13379.html
Sent from the Apache
flink-user-mailing-list-archive.2336050.n4.nabble.com/Duplicated-data-when-using-Externalized-Checkpoints-in-a-Flink-Highly-Available-cluster-tp13301.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
hanks,
Amara
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Duplicated-data-when-using-Externalized-Checkpoints-in-a-Flink-Highly-Available-cluster-tp13301.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
