shekhars-li opened a new pull request, #1682: URL: https://github.com/apache/samza/pull/1682
Bug: taskRestoreManagers.close() which in return calls blobStoreManager.close(), is called before the future for restoreDeletedSnapshots completes. This should only be called when all the futures are returned and complete. Fix: Close taskRestoreManagers after the restore as well as recovery of deleted snapshots (which also involves restore) are returned and complete. Init the blobStoreManager returned by factory, to avoid any race condition of calling operations on a closed blobStoreManager. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
