How to perform stateless restarts with checkpointing enabled?

2024-05-09 Thread Kartikey Pant
We have a source/sink mechanism which uses checkpoints for persistence and can operate in a minor data loss scenario. Is there a method to use checkpoints (to enable use of those source/sink operators) while disabling stateful recovery during restarts? Our setup uses Flink 1.16.1 alongside Flink K

Customisable Triggers on Table API (Java)

2023-03-01 Thread Kartikey Pant via user
that could help us in this case? Thanks, Kartikey Pant