fix: ts-server+promBinOp bug fix (openGemini#603)

Signed-off-by: lihanxue <[email protected]>

Author: lihanxue

engine/executor/pipeline_executor.go

@@ -1363,13 +1363,16 @@ func (builder *ExecutorBuilder) addColStoreReader(node *LogicalColumnStoreReader
 	}
 }
 
-func (builder *ExecutorBuilder) isMultiMstPlanNode(node hybridqp.QueryNode) bool {
+func (builder *ExecutorBuilder) IsMultiMstPlanNode(node hybridqp.QueryNode) bool {
 	if _, ok := node.(*LogicalFullJoin); ok {
 		return true
 	}
 	if _, ok := node.(*LogicalSortAppend); ok {
 		return true
 	}
+	if _, ok := node.(*LogicalBinOp); ok {
+		return true
+	}
 	return false
 }
 
@@ -1387,7 +1390,7 @@ func (builder *ExecutorBuilder) addDefaultNode(node hybridqp.QueryNode) (*Transf
 			continue
 		}
 		children = append(children, child)
-		if builder.isMultiMstPlanNode(node) {
+		if builder.IsMultiMstPlanNode(node) {
 			builder.NextMst()
 		}
 	}

engine/executor/pipeline_executor_test.go

@@ -2109,3 +2109,9 @@ func TestExecutorBuilder_addPartitionExchange1(t *testing.T) {
 	pipelineExecutor := p.(*executor.PipelineExecutor)
 	require.Equal(t, pipelineExecutor.GetProcessors().Empty(), true)
 }
+
+func TestIsMultiMstPlanNode(t *testing.T) {
+	node := &executor.LogicalBinOp{}
+	builder := &executor.ExecutorBuilder{}
+	assert.Equal(t, builder.IsMultiMstPlanNode(node), true)
+}