diff options
| -rw-r--r-- | ydb/core/kqp/federated_query/kqp_federated_query_helpers.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/ydb/core/kqp/federated_query/kqp_federated_query_helpers.cpp b/ydb/core/kqp/federated_query/kqp_federated_query_helpers.cpp index 9aa5d2a86a..0e9ededb62 100644 --- a/ydb/core/kqp/federated_query/kqp_federated_query_helpers.cpp +++ b/ydb/core/kqp/federated_query/kqp_federated_query_helpers.cpp @@ -120,10 +120,8 @@ namespace NKikimr::NKqp { YtGateway}; // Init DatabaseAsyncResolver only if all requirements are met - if (DatabaseResolverActorId && - GenericGatewaysConfig.HasMdbGateway() && - GenericGatewaysConfig.HasYdbMvpEndpoint() && - MdbEndpointGenerator) { + if (DatabaseResolverActorId && MdbEndpointGenerator && + (GenericGatewaysConfig.HasMdbGateway() || GenericGatewaysConfig.HasYdbMvpEndpoint())) { result.DatabaseAsyncResolver = std::make_shared<NFq::TDatabaseAsyncResolverImpl>( actorSystem, DatabaseResolverActorId.value(), |