Github user rmetzger commented on the issue:
https://github.com/apache/bahir-flink/pull/25
Thanks a lot for the pull request. Integrating checkpointing with external
connectors is usually a tricky topic. Before we can merge this change, I'd like
to fully understand the problem first.
Does the Jedis library buffer writes internally? This would interfere with
the checkpointing (like its the case with Flink's Kafka connector), but I don't
think that jedis is buffering.
---
