diff options
| author | ulya-sidorina <yulia@ydb.tech> | 2023-03-01 23:22:14 +0300 |
|---|---|---|
| committer | ulya-sidorina <yulia@ydb.tech> | 2023-03-01 23:22:14 +0300 |
| commit | 093b04166b8440db82cf0590a4beb6c5e8cd5668 (patch) | |
| tree | 65e2308040b67f5b7d3f12a26bea4b135fd99e79 | |
| parent | a60b817418e3a1c43b5b6da6e9c31c5130482e9b (diff) | |
| download | ydb-093b04166b8440db82cf0590a4beb6c5e8cd5668.tar.gz | |
add activity type for kqp source read actor
fix(kqp): add activity type for source read actor
| -rw-r--r-- | ydb/core/kqp/runtime/kqp_read_actor.cpp | 4 | ||||
| -rw-r--r-- | ydb/core/protos/services.proto | 1 |
2 files changed, 5 insertions, 0 deletions
diff --git a/ydb/core/kqp/runtime/kqp_read_actor.cpp b/ydb/core/kqp/runtime/kqp_read_actor.cpp index 2fe5f3c7646..355cf7a3e18 100644 --- a/ydb/core/kqp/runtime/kqp_read_actor.cpp +++ b/ydb/core/kqp/runtime/kqp_read_actor.cpp @@ -369,6 +369,10 @@ public: Counters->ReadActorsCount->Inc(); } + static constexpr NKikimrServices::TActivity::EType ActorActivityType() { + return NKikimrServices::TActivity::KQP_SOURCE_READ_ACTOR; + } + virtual ~TKqpReadActor() { if (!Results.empty() && Alloc) { TGuard<NMiniKQL::TScopedAlloc> allocGuard(*Alloc); diff --git a/ydb/core/protos/services.proto b/ydb/core/protos/services.proto index b0b1760425c..e575e1c165a 100644 --- a/ydb/core/protos/services.proto +++ b/ydb/core/protos/services.proto @@ -974,5 +974,6 @@ message TActivity { DISCOVERY_ACTOR = 607; DISCOVERY_CACHE_ACTOR = 608; REPLICATION_SERVICE = 609; + KQP_SOURCE_READ_ACTOR = 610; }; }; |