-
Notifications
You must be signed in to change notification settings - Fork 1.2k
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
fix:slave parse tnx binlog failed #2642
Conversation
Expect(r2.Err()).NotTo(HaveOccurred()) | ||
Expect(r2.Val()).To(Equal([]interface{}{"OK", "OK"})) | ||
|
||
time.Sleep(100 * time.Millisecond) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这里等待时间可以改大一些,比如3s,避免线上机器因为性能差同步不及时导致测试失败
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这里等待时间可以改大一些,比如3s,避免线上机器因为性能差同步不及时导致测试失败
done
Expect(setkey1.Err()).NotTo(HaveOccurred()) | ||
Expect(setkey1.Val()).To(Equal("QUEUED")) | ||
|
||
setkey2 := clientMaster.Set(ctx, "key2", "value2", 0) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
建议这些key加上前缀, 让他独特一些,避免slave本身就有这些key而导致误判
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
建议这些key加上前缀, 让他独特一些,避免slave本身就有这些key而导致误判
done
@@ -738,6 +738,48 @@ var _ = Describe("should replication ", func() { | |||
Expect(r.Err()).To(MatchError("ERR EXEC without MULTI")) | |||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
可以加上一行注释说明这个测试的目的是为了issue2643:
//The test below is related with issue: #2643
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
可以加上一行注释说明这个测试的目的是为了issue2643: //The test below is related with issue: #2643
done
* fix:slave parse tnx binlog failed * fix:slave parse tnx binlog failed --------- Co-authored-by: chejinge <[email protected]>
* fix:slave parse tnx binlog failed * fix:slave parse tnx binlog failed --------- Co-authored-by: chejinge <[email protected]>
* fix:slave parse tnx binlog failed * fix:slave parse tnx binlog failed --------- Co-authored-by: chejinge <[email protected]>
* fix:slave parse tnx binlog failed * fix:slave parse tnx binlog failed --------- Co-authored-by: chejinge <[email protected]>
* fix:slave parse tnx binlog failed * fix:slave parse tnx binlog failed --------- Co-authored-by: chejinge <[email protected]>
#2643