diff options
| author | ssmike <ssmike@ydb.tech> | 2023-04-06 15:27:54 +0300 |
|---|---|---|
| committer | ssmike <ssmike@ydb.tech> | 2023-04-06 15:27:54 +0300 |
| commit | a18251173ebfcd62901cddca4ed0c2f9029725c7 (patch) | |
| tree | 20b6f95ab01f0097179230825b5ae4ee8277f69b | |
| parent | 7ac34b2f3251a82281b1c3a81e70029ea9de7305 (diff) | |
| download | ydb-a18251173ebfcd62901cddca4ed0c2f9029725c7.tar.gz | |
remove excess notify
| -rw-r--r-- | ydb/core/kqp/runtime/kqp_read_actor.cpp | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/ydb/core/kqp/runtime/kqp_read_actor.cpp b/ydb/core/kqp/runtime/kqp_read_actor.cpp index acb89d7a83f..d8239d21834 100644 --- a/ydb/core/kqp/runtime/kqp_read_actor.cpp +++ b/ydb/core/kqp/runtime/kqp_read_actor.cpp @@ -1188,10 +1188,6 @@ public: << " has limit " << (Settings.GetItemsLimit() != 0) << " limit reached " << LimitReached()); - if (!Results.empty()) { - NotifyCA(); - } - return bytes; } |