summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorgvit <[email protected]>2022-12-28 21:38:13 +0300
committergvit <[email protected]>2022-12-28 21:38:13 +0300
commit8a14abfc4fd6862e47fc1f3f17b50e7fb4adf497 (patch)
tree4887d5a87c4832fdf6119a40af92b9e6cd034a60
parent17fa3898b268ecfd63172c8d34609e32948cf07f (diff)
use public api format in data queries
-rw-r--r--ydb/core/grpc_services/rpc_execute_data_query.cpp2
-rw-r--r--ydb/core/kqp/proxy_service/kqp_proxy_service.cpp2
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;