Hi Eron,
Very interesting idea to support exactly once semantics for sinks via
Git! I would be curious about the performance of such a sink.
Since this currently works on local file systems only (throws an
Exception otherwise), I wonder how does it work on failures when the
"git-${subtaskIndex}"
Hello,
On a long plane trip I had some fun with writing a Flink streaming connector
based on Git. https://github.com/EronWright/flink-git
Not intended for real application use; flink-git is just an experiment meant
for discussion.
Flink's Kafka connector provides exactly-once guarantees when ac
