Fix GetColumnSerializationStats and ResourceSubscriber task name (#1618)

ydb-platform · Feb 6, 2024 · a35afbc · a35afbc
1 parent 24789bc
commit a35afbc
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/ydb/core/tx/columnshard/normalizer/abstract/abstract.h b/ydb/core/tx/columnshard/normalizer/abstract/abstract.h
@@ -101,7 +101,7 @@ namespace NKikimr::NOlap {
     public:
         TNormalizationController(std::shared_ptr<IStoragesManager> storagesManager, const std::shared_ptr<NOlap::NResourceBroker::NSubscribe::TSubscriberCounters>& counters)
             : StoragesManager(storagesManager)
-            , TaskSubscription("CS:NORMALIZER", counters) {}
+            , TaskSubscription("CS::NORMALIZER", counters) {}
 
         const NOlap::NResourceBroker::NSubscribe::TTaskContext& GetTaskSubscription() const {
             return TaskSubscription;

diff --git a/ydb/core/tx/columnshard/splitter/batch_slice.h b/ydb/core/tx/columnshard/splitter/batch_slice.h
@@ -73,7 +73,11 @@ class TDefaultSchemaDetails: public ISchemaDetailInfo {
     }
 
     virtual std::optional<TColumnSerializationStat> GetColumnSerializationStats(const ui32 columnId) const override {
-        return Stats->GetColumnInfo(columnId);
+        auto stats = Stats->GetColumnInfo(columnId);
+        if (stats && stats->GetRecordsCount() != 0) {
+            return stats;
+        }
+        return std::nullopt;
     }
     virtual std::optional<TBatchSerializationStat> GetBatchSerializationStats(const std::shared_ptr<arrow::RecordBatch>& rb) const override {
         return Stats->GetStatsForRecordBatch(rb);