aboutsummaryrefslogtreecommitdiff
path: root/weed/s3api
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2022-06-01 13:35:55 -0700
committerGitHub <noreply@github.com>2022-06-01 13:35:55 -0700
commite152dc8faeb329613c959de7964fd08f04344245 (patch)
tree0795b931e9ce6c7b147cff99159c68959bfffd26 /weed/s3api
parent6793bc853c8b54823157bda6af4385411f8f6aea (diff)
parent02ae102731496689885dd133e2b6aa57ba634b4e (diff)
downloadseaweedfs-e152dc8faeb329613c959de7964fd08f04344245.tar.xz
seaweedfs-e152dc8faeb329613c959de7964fd08f04344245.zip
Merge pull request #3132 from creeew/hotfix/filer_sync_recover
fix filer.sync missing source srv uploaded files to target when targe…
Diffstat (limited to 'weed/s3api')
-rw-r--r--weed/s3api/auth_credentials_subscribe.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/s3api/auth_credentials_subscribe.go b/weed/s3api/auth_credentials_subscribe.go
index 48c4e35c8..91fd5d830 100644
--- a/weed/s3api/auth_credentials_subscribe.go
+++ b/weed/s3api/auth_credentials_subscribe.go
@@ -33,7 +33,7 @@ func (s3a *S3ApiServer) subscribeMetaEvents(clientName string, prefix string, la
}
util.RetryForever("followIamChanges", func() error {
- return pb.WithFilerClientFollowMetadata(s3a, clientName, s3a.randomClientId, prefix, &lastTsNs, 0, 0, processEventFn, true)
+ return pb.WithFilerClientFollowMetadata(s3a, clientName, s3a.randomClientId, prefix, &lastTsNs, 0, 0, processEventFn, pb.FatalOnError)
}, func(err error) bool {
glog.V(0).Infof("iam follow metadata changes: %v", err)
return true