Skip to content

mirror:not overwrit target object when mirror watch #5193

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 4 commits into from

Conversation

dormanze
Copy link
Contributor

@dormanze dormanze commented Apr 23, 2025

fix #5192

Community Contribution License

All community contributions in this pull request are licensed to the project maintainers
under the terms of the Apache 2 license.
By creating this pull request I represent that I have the right to license the
contributions to the project maintainers under the Apache 2 license.

Description

Motivation and Context

make sure mirror command overwrit same when the watch is used and when the watch command is not used.

How to test this PR?

mc mb local/bucket
mc mb peer/bucket
echo "1" > txt
mc cp txt peer/bucket
mc mirror -w local/bucket peer/bucket
echo "2" > txt
mc cp txt local/bucket
mc cat peer/bucket/txt
mc mb local/bucket
mc mb peer/bucket
echo "3" > txt
mc cp txt peer/bucket
mc mirror -w --overwrite local/bucket peer/bucket
echo "4" > txt
mc cp txt local/bucket
mc cat peer/bucket/txt

Types of changes

  • Bug fix (non-breaking change which fixes an issue)
  • New feature (non-breaking change which adds functionality)
  • Optimization (provides speedup with no functional changes)
  • Breaking change (fix or feature that would cause existing functionality to change)

Checklist:

  • Fixes a regression (If yes, please add commit-id or PR # here)
  • Unit tests added/updated
  • Internal documentation updated
  • Create a documentation update request here

not overwrit target object when mirror watch
@sheiy
Copy link

sheiy commented Apr 25, 2025

@jiuker pls check this pr thanks

@harshavardhana harshavardhana requested a review from jiuker July 13, 2025 18:53
@jiuker
Copy link
Contributor

jiuker commented Jul 18, 2025

Let me test first. Will get back here

@harshavardhana
Copy link
Member

Let me test first. Will get back here

@jiuker ^^?

@jiuker
Copy link
Contributor

jiuker commented Jul 23, 2025

Sorry. I can't reprdouce it.

mc mb local/bucket
mc mb peer/bucket
echo "1" > txt
mc cp txt peer/bucket
mc mirror -w local/bucket peer/bucket
echo "2" > txt
mc cp txt local/bucket
mc cat peer/bucket/txt

And your pr is change around mj.opts.activeActive, is not related to --overwrite

restart mc mirror

mc: <ERROR> Failed to perform mirroring, with error condition (mm-source-mtime) Overwrite not allowed for `http://172.25.244.240:9001/bucket/txt`. Use `--overwrite` to override this behavior.

when mc running
do this shell

echo "5" > txt
mc cp txt minio9000/bucket
mc cat minio9001/bucket/txt
echo "6" > txt
mc cp txt minio9000/bucket
mc cat minio9001/bucket/txt
echo "7" > txt
mc cp txt minio9000/bucket
mc cat minio9001/bucket/txt

echo "8" > txt
# a new object to source
mc cp txt minio9000/bucket/txt2
mc cat minio9001/bucket/txt2

root@jiuker:/mnt/d/workspace/go/src/eos/stage# mc cat minio9001/bucket/txt
3
root@jiuker:/mnt/d/workspace/go/src/eos/stage# sh issue_mc_5193.sh 
/mnt/d/workspace/go/src/eos/stage/txt:  2 B / 2 B ┃▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓┃ 26 B/s 0s
3
/mnt/d/workspace/go/src/eos/stage/txt:  2 B / 2 B ┃▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓┃ 27 B/s 0s
3
/mnt/d/workspace/go/src/eos/stage/txt:  2 B / 2 B ┃▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓┃ 27 B/s 0s
3
/mnt/d/workspace/go/src/eos/stage/txt:  2 B / 2 B ┃▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓┃ 29 B/s 0s
root@jiuker:/mnt/d/workspace/go/src/eos/stage# mc cat minio9001/bucket/txt2
8
root@jiuker:/mnt/d/workspace/go/src/eos/stage#

Couldn't found any issues. Please share more info.

@@ -418,21 +418,23 @@ func (mj *mirrorJob) doRemove(ctx context.Context, sURLs URLs, event EventInfo)
// doMirror - Mirror an object to multiple destination. URLs status contains a copy of sURLs and error if any.
func (mj *mirrorJob) doMirrorWatch(ctx context.Context, targetPath string, tgtSSE encrypt.ServerSide, sURLs URLs, event EventInfo) URLs {
shouldQueue := false
if !mj.opts.isOverwrite && !mj.opts.activeActive {
if !mj.opts.isOverwrite {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

not related to --overwrite

}
if shouldQueue || mj.opts.isOverwrite || mj.opts.activeActive {
if shouldQueue || mj.opts.isOverwrite {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

not related to --overwrite

targetClient, err := newClient(targetPath)
if err != nil {
// cannot create targetclient
return sURLs.WithError(err)
}
_, err = targetClient.Stat(ctx, StatOptions{sse: tgtSSE})
if err == nil {
if !sURLs.SourceContent.RetentionEnabled && !sURLs.SourceContent.LegalHoldEnabled {
if !mj.opts.activeActive && !sURLs.SourceContent.RetentionEnabled && !sURLs.SourceContent.LegalHoldEnabled {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

not related to --overwrite

@dormanze
Copy link
Contributor Author

Sorry. I can't reprdouce it.

mc mb local/bucket
mc mb peer/bucket
echo "1" > txt
mc cp txt peer/bucket
mc mirror -w local/bucket peer/bucket
echo "2" > txt
mc cp txt local/bucket
mc cat peer/bucket/txt

And your pr is change around mj.opts.activeActive, is not related to --overwrite

restart mc mirror

mc: <ERROR> Failed to perform mirroring, with error condition (mm-source-mtime) Overwrite not allowed for `http://172.25.244.240:9001/bucket/txt`. Use `--overwrite` to override this behavior.

when mc running do this shell

echo "5" > txt
mc cp txt minio9000/bucket
mc cat minio9001/bucket/txt
echo "6" > txt
mc cp txt minio9000/bucket
mc cat minio9001/bucket/txt
echo "7" > txt
mc cp txt minio9000/bucket
mc cat minio9001/bucket/txt

echo "8" > txt
# a new object to source
mc cp txt minio9000/bucket/txt2
mc cat minio9001/bucket/txt2

root@jiuker:/mnt/d/workspace/go/src/eos/stage# mc cat minio9001/bucket/txt
3
root@jiuker:/mnt/d/workspace/go/src/eos/stage# sh issue_mc_5193.sh 
/mnt/d/workspace/go/src/eos/stage/txt:  2 B / 2 B ┃▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓┃ 26 B/s 0s
3
/mnt/d/workspace/go/src/eos/stage/txt:  2 B / 2 B ┃▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓┃ 27 B/s 0s
3
/mnt/d/workspace/go/src/eos/stage/txt:  2 B / 2 B ┃▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓┃ 27 B/s 0s
3
/mnt/d/workspace/go/src/eos/stage/txt:  2 B / 2 B ┃▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓▓┃ 29 B/s 0s
root@jiuker:/mnt/d/workspace/go/src/eos/stage# mc cat minio9001/bucket/txt2
8
root@jiuker:/mnt/d/workspace/go/src/eos/stage#

Couldn't found any issues. Please share more info.

this #5192 my fixed by #5197, I will close my PR.

@dormanze dormanze closed this Jul 24, 2025
@jiuker
Copy link
Contributor

jiuker commented Jul 24, 2025

Thank you for your contribution.

@dormanze dormanze deleted the watch-overwrite branch July 24, 2025 03:36
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[BUG] mc mirror will overwrite the same key in target minio bucket
4 participants