This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 491d6f3434751f5b13f37194932a84cbf89ca80b Author: Lei Zhang <[email protected]> AuthorDate: Mon Apr 15 22:57:04 2024 +0800 [fix](fe) Fix finalizeCommand `sendAndFlush` NullPointerException (#33420) --- .../main/java/org/apache/doris/qe/ConnectProcessor.java | 17 ++++++----------- 1 file changed, 6 insertions(+), 11 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java index 34beb3c8115..3c993179d76 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java @@ -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(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
