Moved stream lookup join enable under external sources FF

GrigoriyPA · GrigoriyPA · commit a045f0ba56c5 · 2025-10-07T12:51:36.000+03:00
diff --git a/ydb/core/kqp/host/kqp_host.cpp b/ydb/core/kqp/host/kqp_host.cpp
@@ -1964,6 +1964,7 @@ class TKqpHost : public IKqpHost {
             if (FederatedQuerySetup->PqGateway) {
                 InitPqProvider();
             }
+            TypesCtx->StreamLookupJoin = true;
         }
 
         InitPgProvider();
@@ -2007,7 +2008,6 @@ class TKqpHost : public IKqpHost {
         auto configProvider = CreateConfigProvider(*TypesCtx, gatewaysConfig, {}, allowSettings);
         TypesCtx->AddDataSource(ConfigProviderName, configProvider);
         TypesCtx->MatchRecognize = QueryServiceConfig.GetEnableMatchRecognize();
-        TypesCtx->StreamLookupJoin = true;
 
         YQL_ENSURE(TypesCtx->Initialize(*ExprCtx));
 

Original file line number	Diff line number	Diff line change
`@@ -1964,6 +1964,7 @@ class TKqpHost : public IKqpHost {`
`1964`	`1964`	`if (FederatedQuerySetup->PqGateway) {`
`1965`	`1965`	`InitPqProvider();`
`1966`	`1966`	`}`
	`1967`	`+ TypesCtx->StreamLookupJoin = true;`
`1967`	`1968`	`}`
`1968`	`1969`
`1969`	`1970`	`InitPgProvider();`
`@@ -2007,7 +2008,6 @@ class TKqpHost : public IKqpHost {`
`2007`	`2008`	`auto configProvider = CreateConfigProvider(*TypesCtx, gatewaysConfig, {}, allowSettings);`
`2008`	`2009`	`TypesCtx->AddDataSource(ConfigProviderName, configProvider);`
`2009`	`2010`	`TypesCtx->MatchRecognize = QueryServiceConfig.GetEnableMatchRecognize();`
`2010`		`- TypesCtx->StreamLookupJoin = true;`
`2011`	`2011`
`2012`	`2012`	`YQL_ENSURE(TypesCtx->Initialize(*ExprCtx));`
`2013`	`2013`