diff --git a/src/main/java/com/actiontech/dble/statistic/sql/StatisticRecord.java b/src/main/java/com/actiontech/dble/statistic/sql/StatisticRecord.java index accba0a3f..80cfbf748 100644 --- a/src/main/java/com/actiontech/dble/statistic/sql/StatisticRecord.java +++ b/src/main/java/com/actiontech/dble/statistic/sql/StatisticRecord.java @@ -228,6 +228,8 @@ public class StatisticRecord { protected void pushBackendSql(StatisticBackendSqlEntry backendSqlEntry) { if (backendSqlEntry != null && !backendSqlEntry.isEnd()) { backendSqlEntry.setEnd(true); + if (backendSqlEntry.getSql() == null) + return; StatisticManager.getInstance().push(backendSqlEntry); } }