agresch commented on a change in pull request #3363:
URL: https://github.com/apache/storm/pull/3363#discussion_r555278517
##########
File path: storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java
##########
@@ -3815,6 +3828,7 @@ public void setBlobMeta(String key, SettableBlobMeta meta)
throws AuthorizationException, KeyNotFoundException, TException {
try {
blobStore.setBlobMeta(key, meta, getSubject());
+ blobStore.updateLastModTime();
Review comment:
If the updateLastModTime fails, eventually a Nimbus should get restarted
or HDFS fixed, and Nimbus will call blobStore.validateModTime(). This should
fix the issue. During the period in-between, supervisors will remain on an
older version of the blob.
----------------------------------------------------------------
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]
