diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-06-29 16:21:16 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-06-29 16:21:16 +0500 |
| commit | bcbdc4cb37027be16810d0307676a3f7372f30e1 (patch) | |
| tree | f155bc55e3dfe79bc864183f975c4d395c3cb334 /weed/replication | |
| parent | c6e6e303db12b61b899b62bfda7f65ae48f6e01c (diff) | |
| download | seaweedfs-bcbdc4cb37027be16810d0307676a3f7372f30e1.tar.xz seaweedfs-bcbdc4cb37027be16810d0307676a3f7372f30e1.zip | |
use const multipart uploads folder
avoid error bucket NotEmpty if multipart uploads folder exist
Diffstat (limited to 'weed/replication')
| -rw-r--r-- | weed/replication/sink/localsink/local_sink.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/replication/sink/localsink/local_sink.go b/weed/replication/sink/localsink/local_sink.go index f3d3862ee..0a2109a22 100644 --- a/weed/replication/sink/localsink/local_sink.go +++ b/weed/replication/sink/localsink/local_sink.go @@ -7,6 +7,7 @@ import ( "github.com/chrislusf/seaweedfs/weed/replication/repl_util" "github.com/chrislusf/seaweedfs/weed/replication/sink" "github.com/chrislusf/seaweedfs/weed/replication/source" + "github.com/chrislusf/seaweedfs/weed/s3api/s3_constants" "github.com/chrislusf/seaweedfs/weed/util" "os" "path/filepath" @@ -32,7 +33,7 @@ func (localsink *LocalSink) GetName() string { } func (localsink *LocalSink) isMultiPartEntry(key string) bool { - return strings.HasSuffix(key, ".part") && strings.Contains(key, "/.uploads/") + return strings.HasSuffix(key, ".part") && strings.Contains(key, "/"+s3_constants.MultipartUploadsFolder+"/") } func (localsink *LocalSink) initialize(dir string, isIncremental bool) error { |