Please sign in to comment.
fix: In logical decoding the if the backend was requesting a reply we… (
#1467) * Do not call processCopyResults in flush * Use System.nanos() instead of currentTimeMillis() * Added lock into processCopyResults * ignore concurrent requests to processCopyResults * reset the processingCopyResults in a try-finally block
- Loading branch information...
Showing with 188 additions and 154 deletions.
Oops, something went wrong.