fix RawBytes counter (ydb-platform#14594)

GrigoriyPA · Feb 15, 2025 · 709b413 · 709b413
1 parent e3bc3bd
commit 709b413
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 1 deletion.
diff --git a/ydb/core/kqp/ut/olap/kqp_olap_stats_ut.cpp b/ydb/core/kqp/ut/olap/kqp_olap_stats_ut.cpp
@@ -3,6 +3,9 @@
 #include <ydb/core/testlib/common_helper.h>
 #include <ydb/core/tx/columnshard/hooks/testing/controller.h>
 
+#include <ut/olap/helpers/get_value.h>
+#include <ut/olap/helpers/query_executor.h>
+
 namespace NKikimr {
 namespace NKqp {
 
@@ -196,6 +199,23 @@ Y_UNIT_TEST_SUITE(KqpOlapStats) {
         const auto& storeDescription = describeStoreResult.GetTableDescription();
 
         UNIT_ASSERT_VALUES_EQUAL(2000, storeDescription.GetTableRows());
+
+        {
+            auto selectQuery = TString(R"(
+                SELECT
+                    SUM(ColumnBlobBytes) AS BlobBytes,
+                    SUM(ColumnRawBytes) AS RawBytes,
+                    SUM(Rows) AS Rows,
+                    COUNT(*) AS Portions
+                FROM `/Root/TableStoreTest/.sys/store_primary_index_portion_stats`
+            )");
+
+            auto client = testHelper.GetKikimr().GetTableClient();
+            auto rows = ExecuteScanQuery(client, selectQuery);
+            UNIT_ASSERT_VALUES_EQUAL(rows.size(), 1);
+            UNIT_ASSERT_VALUES_EQUAL(GetUint64(rows[0].at("Rows")), storeDescription.GetTableRows());
+            UNIT_ASSERT_VALUES_EQUAL(GetUint64(rows[0].at("BlobBytes")), storeDescription.GetTableSize());
+        }
     }
 }
 

diff --git a/ydb/core/tx/columnshard/counters/portions.h b/ydb/core/tx/columnshard/counters/portions.h
@@ -55,7 +55,7 @@ class TSimplePortionsGroupInfo {
     TSimplePortionsGroupInfo& operator+=(const TSimplePortionsGroupInfo& item) {
         Blobs += item.Blobs;
         BlobBytes += item.BlobBytes;
-        RawBytes += RawBytes + item.RawBytes;
+        RawBytes += item.RawBytes;
         Count += item.Count;
         RecordsCount += item.RecordsCount;
         for (const auto& [channel, bytes] : item.BytesByChannel) {