aboutsummaryrefslogtreecommitdiff
path: root/weed
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2021-12-14 19:48:31 -0800
committerchrislu <chris.lu@gmail.com>2021-12-14 19:48:31 -0800
commitbf4d7affc06d8cf04bb5403da3b9f3e6111e07f8 (patch)
tree949cbc7ebcb4d391f077107c5693a9003db15fd3 /weed
parent8dca561bd1497366699b7e25f10fdbea52edf859 (diff)
downloadseaweedfs-bf4d7affc06d8cf04bb5403da3b9f3e6111e07f8.tar.xz
seaweedfs-bf4d7affc06d8cf04bb5403da3b9f3e6111e07f8.zip
gateway to remote object store: skip replicating multipart upload part files
fix https://github.com/chrislusf/seaweedfs/issues/2509
Diffstat (limited to 'weed')
-rw-r--r--weed/command/filer_remote_gateway_buckets.go3
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/command/filer_remote_gateway_buckets.go b/weed/command/filer_remote_gateway_buckets.go
index af851e2b9..fc11cdbc5 100644
--- a/weed/command/filer_remote_gateway_buckets.go
+++ b/weed/command/filer_remote_gateway_buckets.go
@@ -181,6 +181,9 @@ func (option *RemoteGatewayOptions) makeBucketedEventProcessor(filerSource *sour
if message.NewParentPath == option.bucketsDir {
return handleCreateBucket(message.NewEntry)
}
+ if strings.HasPrefix(message.NewParentPath, option.bucketsDir) && strings.Contains(message.NewParentPath, "/.uploads/") {
+ return nil
+ }
if !filer.HasData(message.NewEntry) {
return nil
}