Add debug for inner join

Xuanwo · Xuanwo · commit 6e26b301e8b6 · 2025-02-11T19:07:55.000+08:00
Signed-off-by: Xuanwo &lt;github@xuanwo.io&gt;
diff --git a/src/query/service/src/pipelines/processors/transforms/hash_join/probe_join/inner_join.rs b/src/query/service/src/pipelines/processors/transforms/hash_join/probe_join/inner_join.rs
@@ -90,9 +90,10 @@ impl HashJoinProbeState {
                 }
 
                 if FROM_LEFT_SINGLE && match_count > 1 {
-                    return Err(ErrorCode::Internal(
-                        "Scalar subquery can't return more than one row",
-                    ));
+                    return Err(ErrorCode::Internal(format!(
+                        "Scalar subquery can't return more than one row, but got {}",
+                        match_count
+                    )));
                 }
 
                 // Fill `probe_indexes`.

Original file line number	Diff line number	Diff line change
`@@ -90,9 +90,10 @@ impl HashJoinProbeState {`
`90`	`90`	`}`
`91`	`91`
`92`	`92`	`if FROM_LEFT_SINGLE && match_count > 1 {`
`93`		`- return Err(ErrorCode::Internal(`
`94`		`- "Scalar subquery can't return more than one row",`
`95`		`- ));`
	`93`	`+ return Err(ErrorCode::Internal(format!(`
	`94`	`+ "Scalar subquery can't return more than one row, but got {}",`
	`95`	`+ match_count`
	`96`	`+ )));`
`96`	`97`	`}`
`97`	`98`
`98`	`99`	// Fill `probe_indexes`.