diff options
| author | ivanmorozov <ivanmorozov@yandex-team.com> | 2022-10-22 13:45:12 +0300 |
|---|---|---|
| committer | ivanmorozov <ivanmorozov@yandex-team.com> | 2022-10-22 13:45:12 +0300 |
| commit | baf50b019c76193f85d68bcd9529824c7c2a6c98 (patch) | |
| tree | 56cd859b81ccd996ebf9c5a38724b7fa25cedbae | |
| parent | cfa801e12eec1f1845ed0d01f2c44888eefc1ba2 (diff) | |
| download | ydb-baf50b019c76193f85d68bcd9529824c7c2a6c98.tar.gz | |
fix for absolutely zero reply
| -rw-r--r-- | ydb/core/kqp/compute_actor/kqp_scan_compute_actor.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/kqp/ut/kqp_olap_ut.cpp | 3 |
2 files changed, 1 insertions, 4 deletions
diff --git a/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.cpp b/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.cpp index b23b02f5d18..651f69e60ca 100644 --- a/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.cpp +++ b/ydb/core/kqp/compute_actor/kqp_scan_compute_actor.cpp @@ -1106,7 +1106,7 @@ private: const ui64 prevFreeSpace = std::any_cast<ui64>(prev); return freeSpace > prevFreeSpace; }; - if (!hasNewMemoryPred()) { + if (!hasNewMemoryPred() && ScanData->GetStoredBytes()) { return; } CA_LOG_D("POLL_SOURCES:START:" << InFlightShards.GetShardsCount() << "." << InFlightShards.GetScansCount()); diff --git a/ydb/core/kqp/ut/kqp_olap_ut.cpp b/ydb/core/kqp/ut/kqp_olap_ut.cpp index 2e63ab1b94e..4741d7e8dfc 100644 --- a/ydb/core/kqp/ut/kqp_olap_ut.cpp +++ b/ydb/core/kqp/ut/kqp_olap_ut.cpp @@ -2168,9 +2168,6 @@ Y_UNIT_TEST_SUITE(KqpOlap) { } Y_UNIT_TEST(ManyColumnShardsFilterPushdownEmptySet) { - // uncomment this line to reproduce the bug - return; - TPortManager tp; ui16 mbusport = tp.GetPort(2134); auto settings = Tests::TServerSettings(mbusport) |