diff options
| author | gvit <[email protected]> | 2022-12-28 21:38:13 +0300 |
|---|---|---|
| committer | gvit <[email protected]> | 2022-12-28 21:38:13 +0300 |
| commit | 8a14abfc4fd6862e47fc1f3f17b50e7fb4adf497 (patch) | |
| tree | 4887d5a87c4832fdf6119a40af92b9e6cd034a60 | |
| parent | 17fa3898b268ecfd63172c8d34609e32948cf07f (diff) | |
use public api format in data queries
| -rw-r--r-- | ydb/core/grpc_services/rpc_execute_data_query.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/kqp/proxy_service/kqp_proxy_service.cpp | 2 |
2 files changed, 1 insertions, 3 deletions
diff --git a/ydb/core/grpc_services/rpc_execute_data_query.cpp b/ydb/core/grpc_services/rpc_execute_data_query.cpp index 7d04f7cec55..a71133cb646 100644 --- a/ydb/core/grpc_services/rpc_execute_data_query.cpp +++ b/ydb/core/grpc_services/rpc_execute_data_query.cpp @@ -32,7 +32,7 @@ void SerializeQueryRequest(std::shared_ptr<NGRpcService::IRequestCtxMtSafe>& in, SetDatabase(*dst, *in.get()); dst->MutableRequest()->SetSessionId(req->session_id()); - dst->MutableRequest()->SetUsePublicResponseDataFormat(false); + dst->MutableRequest()->SetUsePublicResponseDataFormat(true); if (auto traceId = in->GetTraceId()) { dst->SetTraceId(traceId.GetRef()); diff --git a/ydb/core/kqp/proxy_service/kqp_proxy_service.cpp b/ydb/core/kqp/proxy_service/kqp_proxy_service.cpp index d16ec85ccea..9dee2b8d195 100644 --- a/ydb/core/kqp/proxy_service/kqp_proxy_service.cpp +++ b/ydb/core/kqp/proxy_service/kqp_proxy_service.cpp @@ -523,8 +523,6 @@ public: if (sessionInfo) { targetId = sessionInfo->WorkerId; } else { - // No local session. Disable public format due to compatibility. - request.SetUsePublicResponseDataFormat(false); targetId = TryGetSessionTargetActor(request.GetSessionId(), requestInfo, requestId); if (!targetId) { return; |
