wilke-christopher opened a new issue, #7978: URL: https://github.com/apache/storm/issues/7978
I have a Storm (2.8.0) cluster with 3 Nimbus and 3 Supervisor servers and replication count 3. When submitting a new topolgy I sometimes get the ERROR `Could not download the blob with key: ...`. The error occurs when the `LocalFsBlobStoreSynchronizer` determines the missing blob keys during synchronization. But the function `BlobStoreUtils.downloadMissingBlob` throws a `KeyAlreadyExistsException`, which is logged with INFO. In my opinion, `isSucess` should be set to `true` at this point and the loop exited. The actual error is logged after all other Nimbus servers have been iterated over and each iteration has ended unsuccessfully with a `KeyAlreadyExistsException`. The `KeyAlreadyExistsException` is thrown because the corresponding blob file already exists in the file system. I am not sure if either `LocalFsBlobStoreSynchronizer.getBlobStoreKeySet()` returns an inconsistent key set or the blob file has already been created in parallel. I have attached the relevant Nimbus log. I am grateful for any help. [blobstore_error.log](https://github.com/user-attachments/files/19012609/blobstore_error.log) -- 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: dev-unsubscr...@storm.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
