From ab6f1c36d4fdebe75bd10fdebfd1b07115baef10 Mon Sep 17 00:00:00 2001 From: cpegeric Date: Tue, 13 May 2025 10:46:28 +0100 Subject: [PATCH] resolve subscription schema name if subscription name not empty --- pkg/sql/plan/apply_indices_fulltext.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/pkg/sql/plan/apply_indices_fulltext.go b/pkg/sql/plan/apply_indices_fulltext.go index 19d62ce35ef78..978c4db79a052 100644 --- a/pkg/sql/plan/apply_indices_fulltext.go +++ b/pkg/sql/plan/apply_indices_fulltext.go @@ -232,11 +232,17 @@ func (builder *QueryBuilder) applyJoinFullTextIndices(nodeID int32, projNode *pl var last_node_id int32 var last_ftnode_pkcol *Expr + srcTblSchema := scanNode.ObjRef.SchemaName + if len(scanNode.ObjRef.SubscriptionName) > 0 { + srcTblSchema = scanNode.ObjRef.SubscriptionName + } + for i := 0; i < len(ft_filters); i++ { ftidxscan := ft_filters[i] idxdef := indexDefs[i] - idxtblname := fmt.Sprintf("`%s`.`%s`", scanNode.ObjRef.SchemaName, idxdef.IndexTableName) - srctblname := fmt.Sprintf("`%s`.`%s`", scanNode.ObjRef.SchemaName, scanNode.TableDef.Name) + + idxtblname := fmt.Sprintf("`%s`.`%s`", srcTblSchema, idxdef.IndexTableName) + srctblname := fmt.Sprintf("`%s`.`%s`", srcTblSchema, scanNode.TableDef.Name) fn := ftidxscan.GetF() pattern := fn.Args[0].GetLit().GetSval() mode := fn.Args[1].GetLit().GetI64Val()