commitIfEliglble methods gets called by scheduler as well as on completion of append calls. There is a race condition which can lead to 'STREAM ALREADY COMMITTED' error.
This PR fixes task failure due to concurrent stream commit by adding synchronisation and adding conditional check before attempting commit. This PR adds more logging .
commitIfEliglblemethods gets called by scheduler as well as on completion of append calls. There is a race condition which can lead to 'STREAM ALREADY COMMITTED' error. This PR fixes task failure due to concurrent stream commit by adding synchronisation and adding conditional check before attempting commit. This PR adds more logging .