database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](mysql-channel) initialize mysql serializer by default (#31083)

Browse Source
This commit is contained in:
Siyang Tang
2024-02-19 15:54:21 +08:00
committed by yiguolei
parent 2f9bd3e3bb
commit 277de979c3
2 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
fe/fe-core/src/main/java/org/apache/doris/mysql/DummyMysqlChannel.java
View File

@ -27,9 +27,6 @@ import java.nio.ByteBuffer;
* And don't need to allocate a real ByteBuffer.
*/
public class DummyMysqlChannel extends MysqlChannel {
public DummyMysqlChannel() {
this.serializer = MysqlSerializer.newInstance();
}
public void setSequenceId(int sequenceId) {
this.sequenceId = sequenceId;

4
fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlChannel.java
View File

@ -75,7 +75,7 @@ public class MysqlChannel {
protected boolean isSslHandshaking;
private SSLEngine sslEngine;
protected volatile MysqlSerializer serializer;
protected volatile MysqlSerializer serializer = MysqlSerializer.newInstance();
// mysql flag CLIENT_DEPRECATE_EOF
private boolean clientDeprecatedEOF;
@ -111,8 +111,6 @@ public class MysqlChannel {
remoteHostPortString = connection.getPeerAddress().toString();
remoteIp = connection.getPeerAddress().toString();
}
// The serializer and buffers should only be created if this is a real MysqlChannel
this.serializer = MysqlSerializer.newInstance();
this.defaultBuffer = ByteBuffer.allocate(16 * 1024);
this.headerByteBuffer = ByteBuffer.allocate(PACKET_HEADER_LEN);
this.sendBuffer = ByteBuffer.allocate(2 * 1024 * 1024);