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

[fix](fe) Fix finalizeCommand sendAndFlush NullPointerException (#33420)

Browse Source
This commit is contained in:
Lei Zhang
2024-04-15 22:57:04 +08:00
committed by yiguolei
parent fe3b6824b3
commit 1fba73eea4
1 changed files with 6 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
View File

@ -484,21 +484,16 @@ public abstract class ConnectProcessor {
} else {
executor.sendResultSet(resultSet);
packet = getResultPacket();
if (packet == null) {
if (LOG.isDebugEnabled()) {
LOG.debug("packet == null");
}
return;
}
}
} else {
packet = getResultPacket();
if (packet == null) {
if (LOG.isDebugEnabled()) {
LOG.debug("packet == null");
}
return;
}
if (packet == null) {
if (LOG.isDebugEnabled()) {
LOG.debug("packet == null");
}
return;
}
MysqlChannel channel = ctx.getMysqlChannel();