Hi all,
I'm building a source connector that relies on the HybridSource and am
running into issues on checkpoint recovery. The source connector relies on
two underlying sources, one that reads from files, and another that
consumes from Kafka. The file source provides offsets that allows me to
resu
Hi Kevin,
We’ve merged the fix into the 1.20 branch, and AFAIK, the community will
kick off the next patch release (1.20.3) soon. In the meantime, if you’re
interested, you may build from the release-1.20 branch[1] to verify the fix.
Thank you again for reporting the issue and for your valuable
Sounds like a pretty bad bug / race condition.
It would be great if you could open a JIRA ticket with this information and
if you could attach the operator logs for maybe possible a slightly smaller
repro case (with for example 2 concurrent jobs if the issue comes up)
Next will be to dive into the
