diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java index d5bf9b9ef2dc1f..51316630afff4b 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java @@ -54,7 +54,6 @@ import org.apache.doris.plsql.Exec; import org.apache.doris.plsql.executor.PlSqlOperation; import org.apache.doris.plugin.AuditEvent.AuditEventBuilder; -import org.apache.doris.proto.Types; import org.apache.doris.resource.Tag; import org.apache.doris.service.arrowflight.results.FlightSqlChannel; import org.apache.doris.statistics.ColumnStatistic; @@ -962,7 +961,7 @@ private void killByTimeout(boolean killConnection) { + " connection type: {}, connectionId: {}", getRemoteHostPortString(), killConnection, getConnectType(), connectionId); - executorRef.cancel(Types.PPlanFragmentCancelReason.TIMEOUT); + executorRef.cancel("Query timeout"); } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java index fee7d0442bf425..7fe5cb7ef19f52 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java @@ -3503,10 +3503,6 @@ public void onSuccess(InternalService.PCancelPlanFragmentResult result) { fragmentId, status.toString()); } } - LOG.warn("Failed to cancel query {} instance initiated={} done={} backend: {}," - + "fragment id={}, reason: {}", - DebugUtil.printId(queryId), initiated, done, backend.getId(), - fragmentId, "without status"); } public void onFailure(Throwable t) {