From 98177a44059d0b3a0f4c0c4d2f58e872d6cf3d0c Mon Sep 17 00:00:00 2001 From: obdev Date: Fri, 23 Feb 2024 03:18:37 +0000 Subject: [PATCH] fix bug, op sort & scan is 0 in long_ops_status which is caused by change of op --- src/rootserver/ddl_task/ob_ddl_task.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/rootserver/ddl_task/ob_ddl_task.cpp b/src/rootserver/ddl_task/ob_ddl_task.cpp index c38c74a5d3..1689a4d416 100644 --- a/src/rootserver/ddl_task/ob_ddl_task.cpp +++ b/src/rootserver/ddl_task/ob_ddl_task.cpp @@ -1571,7 +1571,7 @@ int ObDDLTask::gather_scanned_rows( SMART_VAR(ObMySQLProxy::MySQLResult, scan_res) { if (OB_FAIL(scan_sql.assign_fmt( "SELECT OUTPUT_ROWS FROM %s WHERE TENANT_ID=%lu " - "AND TRACE_ID='%s' AND PLAN_OPERATION='PHY_SUBPLAN_SCAN' AND OTHERSTAT_5_VALUE='%ld'", + "AND TRACE_ID='%s' AND (PLAN_OPERATION='PHY_SUBPLAN_SCAN' OR PLAN_OPERATION='PHY_VEC_SUBPLAN_SCAN') AND OTHERSTAT_5_VALUE='%ld'", OB_ALL_VIRTUAL_SQL_PLAN_MONITOR_TNAME, tenant_id, trace_id_str, task_id))) { LOG_WARN("failed to assign sql", K(ret)); } else if (OB_FAIL(DDL_SIM(tenant_id, task_id, QUERY_SQL_PLAN_MONITOR_SLOW))) { @@ -1621,7 +1621,7 @@ int ObDDLTask::gather_sorted_rows( SMART_VAR(ObMySQLProxy::MySQLResult, sort_res) { if (OB_FAIL(sort_sql.assign_fmt( "SELECT OTHERSTAT_1_VALUE AS ROW_SORTED FROM %s WHERE TENANT_ID=%lu " - "AND TRACE_ID='%s' AND PLAN_OPERATION='PHY_SORT' AND OTHERSTAT_5_VALUE='%ld'", + "AND TRACE_ID='%s' AND (PLAN_OPERATION='PHY_SORT' OR PLAN_OPERATION = 'PHY_VEC_SORT') AND OTHERSTAT_5_VALUE='%ld'", OB_ALL_VIRTUAL_SQL_PLAN_MONITOR_TNAME, tenant_id, trace_id_str, task_id))) { LOG_WARN("failed to assign sql", K(ret)); } else if (OB_FAIL(DDL_SIM(tenant_id, task_id, QUERY_SQL_PLAN_MONITOR_SLOW))) {