diff --git a/pkg/sql/colexec/execplan.go b/pkg/sql/colexec/execplan.go
index b4795b2440a4..37179579ee87 100644
--- a/pkg/sql/colexec/execplan.go
+++ b/pkg/sql/colexec/execplan.go
@@ -882,7 +882,12 @@ func NewColOperator(
 			}
 			result.ColumnTypes = make([]*types.T, len(leftTypes)+len(rightTypes))
 			copy(result.ColumnTypes, leftTypes)
-			copy(result.ColumnTypes[len(leftTypes):], rightTypes)
+			if core.HashJoiner.Type == sqlbase.JoinType_LEFT_SEMI ||
+				core.HashJoiner.Type == sqlbase.JoinType_LEFT_ANTI {
+				result.ColumnTypes = result.ColumnTypes[:len(leftTypes):len(leftTypes)]
+			} else {
+				copy(result.ColumnTypes[len(leftTypes):], rightTypes)
+			}
 
 			if !core.HashJoiner.OnExpr.Empty() && core.HashJoiner.Type == sqlbase.JoinType_INNER {
 				if err = result.planAndMaybeWrapOnExprAsFilter(ctx, flowCtx, core.HashJoiner.OnExpr, streamingMemAccount, processorConstructor); err != nil {
@@ -945,7 +950,12 @@ func NewColOperator(
 			result.ToClose = append(result.ToClose, mj.(IdempotentCloser))
 			result.ColumnTypes = make([]*types.T, len(leftTypes)+len(rightTypes))
 			copy(result.ColumnTypes, leftTypes)
-			copy(result.ColumnTypes[len(leftTypes):], rightTypes)
+			if core.MergeJoiner.Type == sqlbase.JoinType_LEFT_SEMI ||
+				core.MergeJoiner.Type == sqlbase.JoinType_LEFT_ANTI {
+				result.ColumnTypes = result.ColumnTypes[:len(leftTypes):len(leftTypes)]
+			} else {
+				copy(result.ColumnTypes[len(leftTypes):], rightTypes)
+			}
 
 			if onExpr != nil {
 				if err = result.planAndMaybeWrapOnExprAsFilter(ctx, flowCtx, *onExpr, streamingMemAccount, processorConstructor); err != nil {
diff --git a/pkg/sql/logictest/testdata/logic_test/merge_join b/pkg/sql/logictest/testdata/logic_test/merge_join
index 660af64b60f7..d3ea189fc18f 100644
--- a/pkg/sql/logictest/testdata/logic_test/merge_join
+++ b/pkg/sql/logictest/testdata/logic_test/merge_join
@@ -58,3 +58,14 @@ SELECT * FROM t44798_0 NATURAL JOIN t44798_1
 ----
 0
 2
+
+# Regression test for batch type schema prefix mismatch after LEFT ANTI join
+# (48622).
+statement ok
+CREATE TABLE l (l INT PRIMARY KEY); INSERT INTO l VALUES (1), (2);
+CREATE TABLE r (r INT PRIMARY KEY); INSERT INTO r VALUES (1)
+
+query IB
+SELECT *, true FROM (SELECT l FROM l WHERE l NOT IN (SELECT r FROM r))
+----
+2 true