just test

apache · Dec 21, 2022 · 18ff2c6 · 18ff2c6
1 parent 4e53293
commit 18ff2c6
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -2522,13 +2522,6 @@ private void doReput() {
                             DefaultMessageStore.this.commitLog.checkMessageAndReturnSize(result.getByteBuffer(), false, false, false);
                         int size = dispatchRequest.getBufferSize() == -1 ? dispatchRequest.getMsgSize() : dispatchRequest.getBufferSize();
 
-                        if (!dispatchRequest.isSuccess()) {
-                            LOGGER.warn("reputFromOffset = " + reputFromOffset);
-                            LOGGER.warn("confirmOffset = " + DefaultMessageStore.this.getConfirmOffset());
-                            LOGGER.warn("maxOffset = " + DefaultMessageStore.this.getMaxPhyOffset());
-                            LOGGER.warn("" + dispatchRequest.toString());
-                        }
-
                         if (reputFromOffset + size > DefaultMessageStore.this.getConfirmOffset()) {
                             doNext = false;
                             break;