debug

TangSiyang2001 · Aug 14, 2024 · dccc95a · dccc95a
1 parent 35f5e90
commit dccc95a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlChannel.java b/fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlChannel.java
@@ -131,6 +131,7 @@ public void initSslBuffer() {
 
     public void setSequenceId(int sequenceId) {
         this.sequenceId = sequenceId;
+        LOG.info("set seq id to 0");
     }
 
     public String getRemoteIp() {
@@ -172,7 +173,9 @@ private int packetLen(boolean isSslHeader) {
 
     private void accSequenceId() {
         sequenceId++;
+        LOG.info("add seq id to {}", sequenceId);
         if (sequenceId > 255) {
+            LOG.info("reset sequence id");
             sequenceId = 0;
         }
     }
@@ -318,7 +321,7 @@ public ByteBuffer fetchOnePacket() throws IOException {
                 byte[] header = result.array();
                 int packetId = header[3] & 0xFF;
                 if (packetId != sequenceId) {
-                    LOG.warn("receive packet sequence id[" + packetId() + "] want to get[" + sequenceId + "]");
+                    LOG.warn("receive packet sequence id[" + packetId + "] want to get[" + sequenceId + "]");
                     throw new IOException("Bad packet sequence.");
                 }
                 int mysqlPacketLength = (header[0] & 0xFF) | ((header[1] & 0XFF) << 8) | ((header[2] & 0XFF) << 16);