diff options
| author | gvit <gvit@ydb.tech> | 2023-07-26 12:37:37 +0300 |
|---|---|---|
| committer | gvit <gvit@ydb.tech> | 2023-07-26 12:37:37 +0300 |
| commit | e0cab1bab710af9eba68da1d0e063854b936bb28 (patch) | |
| tree | 42c7f28d5b32a5e370c746af8c1f93d39d364e7d | |
| parent | 3f972bd6eb355d1ed5981b9115d43727ee25b522 (diff) | |
| download | ydb-e0cab1bab710af9eba68da1d0e063854b936bb28.tar.gz | |
add ignorefunc to data executer KIKIMR-18848
| -rw-r--r-- | ydb/core/grpc_services/rpc_execute_data_query.cpp | 3 | ||||
| -rw-r--r-- | ydb/core/kqp/executer_actor/kqp_executer.h | 4 |
2 files changed, 7 insertions, 0 deletions
diff --git a/ydb/core/grpc_services/rpc_execute_data_query.cpp b/ydb/core/grpc_services/rpc_execute_data_query.cpp index d315038a16..2242443121 100644 --- a/ydb/core/grpc_services/rpc_execute_data_query.cpp +++ b/ydb/core/grpc_services/rpc_execute_data_query.cpp @@ -11,6 +11,8 @@ #include <ydb/core/ydb_convert/ydb_convert.h> #include <ydb/public/lib/operation_id/operation_id.h> +#include <ydb/core/kqp/executer_actor/kqp_executer.h> + #include <ydb/library/yql/public/issue/yql_issue.h> namespace NKikimr { @@ -44,6 +46,7 @@ public: void StateWork(TAutoPtr<IEventHandle>& ev) { switch (ev->GetTypeRewrite()) { HFunc(NKqp::TEvKqp::TEvQueryResponse, Handle); + IgnoreFunc(NKqp::TEvKqpExecuter::TEvExecuterProgress); default: TBase::StateWork(ev); } } diff --git a/ydb/core/kqp/executer_actor/kqp_executer.h b/ydb/core/kqp/executer_actor/kqp_executer.h index 1cc61beaf8..6eed3ae8f1 100644 --- a/ydb/core/kqp/executer_actor/kqp_executer.h +++ b/ydb/core/kqp/executer_actor/kqp_executer.h @@ -62,6 +62,10 @@ struct TEvKqpExecuter { struct TEvStreamProfile : public TEventPB<TEvStreamProfile, NKikimrKqp::TEvExecuterStreamProfile, TKqpExecuterEvents::EvStreamProfile> {}; + // deprecated event, remove in the future releases. + struct TEvExecuterProgress : public TEventPB<TEvExecuterProgress, NKikimrKqp::TEvExecuterProgress, + TKqpExecuterEvents::EvProgress> {}; + struct TEvTableResolveStatus : public TEventLocal<TEvTableResolveStatus, TKqpExecuterEvents::EvTableResolveStatus> { |