diff options
| author | Sergei Puchin <s.puchin@gmail.com> | 2022-06-20 20:44:33 +0300 |
|---|---|---|
| committer | Sergei Puchin <s.puchin@gmail.com> | 2022-06-20 20:44:33 +0300 |
| commit | cfe2e50abfa852c2d69942c4d255a20147e46343 (patch) | |
| tree | 8ecee135d69c92e6a549401664d10cfb713a0f21 | |
| parent | 13bffcce474f3588b3e177ea6c6015f16ded9ef6 (diff) | |
| download | ydb-cfe2e50abfa852c2d69942c4d255a20147e46343.tar.gz | |
Add TEvUnlink for followers pipe cache. (KIKIMR-15152)
ref:6f663bf2d2a5d180473cad71dd7e42a24b43b10a
| -rw-r--r-- | ydb/core/kqp/executer/kqp_data_executer.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/ydb/core/kqp/executer/kqp_data_executer.cpp b/ydb/core/kqp/executer/kqp_data_executer.cpp index fdafe5cadc..86b1943104 100644 --- a/ydb/core/kqp/executer/kqp_data_executer.cpp +++ b/ydb/core/kqp/executer/kqp_data_executer.cpp @@ -1752,6 +1752,11 @@ private: Counters->TxProxyMon->TxExecuteTimeHgram->Collect(totalTime.MilliSeconds()); Send(MakePipePeNodeCacheID(false), new TEvPipeCache::TEvUnlink(0)); + + if (UseFollowers) { + Send(MakePipePeNodeCacheID(true), new TEvPipeCache::TEvUnlink(0)); + } + TBase::PassAway(); } |