diff options
| author | chrislu <chris.lu@gmail.com> | 2021-12-14 19:48:31 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2021-12-14 19:48:31 -0800 |
| commit | bf4d7affc06d8cf04bb5403da3b9f3e6111e07f8 (patch) | |
| tree | 949cbc7ebcb4d391f077107c5693a9003db15fd3 | |
| parent | 8dca561bd1497366699b7e25f10fdbea52edf859 (diff) | |
| download | seaweedfs-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
| -rw-r--r-- | weed/command/filer_remote_gateway_buckets.go | 3 |
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 } |
