otterc edited a comment on pull request #31934: URL: https://github.com/apache/spark/pull/31934#issuecomment-805493922
> > * If stream2Duplicate encounters a failure now, it has isWriting on and so can reset currentMapId of partition_0_2. This again gives a chance to another stream say stream3 to allowedToWrite without stream2 to complete. > > So, it should be `stream1Duplicate` instead of `stream2Duplicate` here? Right, that was a typo. Yes, it should be `stream1Duplicate`. Thanks for pointing it out. I edited the example as well for others if they go through it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
