opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix flaky test testSemiSyncReplicaWhenAdaptiveDegradation (#7631)

Browse Source
This commit is contained in:
rongtong
2023-12-12 14:17:24 +08:00
committed by GitHub
parent d626d6087d
commit 1e69e3904f
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/test/java/org/apache/rocketmq/store/HATest.java
+9 -6
View File
@@ -213,12 +213,15 @@ public class HATest {
assertEquals(PutMessageStatus.PUT_OK, result.getPutMessageStatus());
//message has been replicated to slave's commitLog, but maybe not dispatch to ConsumeQueue yet
//so direct read from commitLog by physical offset
MessageExt slaveMsg = slaveMessageStore.lookMessageByOffset(result.getAppendMessageResult().getWroteOffset());
assertNotNull(slaveMsg);
assertArrayEquals(msg.getBody(), slaveMsg.getBody());
assertEquals(msg.getTopic(), slaveMsg.getTopic());
assertEquals(msg.getTags(), slaveMsg.getTags());
assertEquals(msg.getKeys(), slaveMsg.getKeys());
final MessageExt[] slaveMsg = {null};
await().atMost(Duration.ofSeconds(3)).until(() -> {
slaveMsg[0] = slaveMessageStore.lookMessageByOffset(result.getAppendMessageResult().getWroteOffset());
return slaveMsg[0] != null;
});
assertArrayEquals(msg.getBody(), slaveMsg[0].getBody());
assertEquals(msg.getTopic(), slaveMsg[0].getTopic());
assertEquals(msg.getTags(), slaveMsg[0].getTags());
assertEquals(msg.getKeys(), slaveMsg[0].getKeys());
}
//shutdown slave, putMessage should return IN_SYNC_REPLICAS_NOT_ENOUGH