Skip to content

Commit 10c76e5

Browse files
committed
Fixes
1 parent 0149a9d commit 10c76e5

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/core/grpc_services/rpc_stream_execute_scan_query.cpp

+2-2
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,7 @@ class TStreamExecuteScanQueryRPC : public TActorBootstrapped<TStreamExecuteScanQ
249249
nullptr
250250
);
251251

252-
ev->Record.MutableRequest()->SetCollectDiagnostics(NeedCollectDiagnostics(*req) || req->Getcollect_full_diagnostics());
252+
ev->Record.MutableRequest()->SetCollectDiagnostics(NeedCollectDiagnostics(*req));
253253

254254
if (!ctx.Send(NKqp::MakeKqpProxyID(ctx.SelfID.NodeId()), ev.Release())) {
255255
NYql::TIssues issues;
@@ -312,7 +312,7 @@ class TStreamExecuteScanQueryRPC : public TActorBootstrapped<TStreamExecuteScanQ
312312

313313
bool reportStats = NeedReportStats(*Request_->GetProtoRequest());
314314
bool reportPlan = reportStats && NeedReportPlan(*Request_->GetProtoRequest());
315-
bool collectDiagnostics = NeedCollectDiagnostics(*Request_->GetProtoRequest()) || Request_->GetProtoRequest()->Getcollect_full_diagnostics();
315+
bool collectDiagnostics = NeedCollectDiagnostics(*Request_->GetProtoRequest());
316316

317317
if (reportStats) {
318318
if (kqpResponse.HasQueryStats()) {

0 commit comments

Comments
 (0)