Moved stream lookup join enable under external sources FF

GrigoriyPA · GrigoriyPA · commit 7894206c5b3d · 2025-10-06T12:06:56.000+03:00
diff --git a/ydb/core/kqp/host/kqp_host.cpp b/ydb/core/kqp/host/kqp_host.cpp
@@ -1962,6 +1962,7 @@ class TKqpHost : public IKqpHost {
             if (FederatedQuerySetup->PqGateway) {
                 InitPqProvider();
             }
+            TypesCtx->StreamLookupJoin = true;
         }
 
         InitPgProvider();
@@ -2005,7 +2006,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
`@@ -1962,6 +1962,7 @@ class TKqpHost : public IKqpHost {`
`1962`	`1962`	`if (FederatedQuerySetup->PqGateway) {`
`1963`	`1963`	`InitPqProvider();`
`1964`	`1964`	`}`
	`1965`	`+ TypesCtx->StreamLookupJoin = true;`
`1965`	`1966`	`}`
`1966`	`1967`
`1967`	`1968`	`InitPgProvider();`
`@@ -2005,7 +2006,6 @@ class TKqpHost : public IKqpHost {`
`2005`	`2006`	`auto configProvider = CreateConfigProvider(*TypesCtx, gatewaysConfig, {}, allowSettings);`
`2006`	`2007`	`TypesCtx->AddDataSource(ConfigProviderName, configProvider);`
`2007`	`2008`	`TypesCtx->MatchRecognize = QueryServiceConfig.GetEnableMatchRecognize();`
`2008`		`- TypesCtx->StreamLookupJoin = true;`
`2009`	`2009`
`2010`	`2010`	`YQL_ENSURE(TypesCtx->Initialize(*ExprCtx));`
`2011`	`2011`