Skip to content

Commit 17b8068

Browse files
Merge bb7dac3 into 283d573
2 parents 283d573 + bb7dac3 commit 17b8068

File tree

6 files changed

+7
-3
lines changed

6 files changed

+7
-3
lines changed

ydb/core/tx/columnshard/engines/defs.h

-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
#include <ydb/core/base/defs.h>
44
#include <ydb/core/base/logoblob.h>
55
#include <ydb/core/tx/ctor_logger.h>
6-
#include <ydb/core/tx/columnshard/common/snapshot.h>
76

87
namespace NKikimr::NOlap {
98

ydb/core/tx/columnshard/engines/filter.h

+1
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
#include "defs.h"
44
#include <ydb/core/formats/arrow/program.h>
55
#include <ydb/core/formats/arrow/replace_key.h>
6+
#include <ydb/core/tx/columnshard/common/snapshot.h>
67

78
namespace NKikimr::NOlap {
89

ydb/core/tx/columnshard/engines/insert_table/data.h

+1
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
#include "meta.h"
33
#include <ydb/core/tx/columnshard/blob.h>
44
#include <ydb/core/tx/columnshard/engines/defs.h>
5+
#include <ydb/core/tx/columnshard/common/snapshot.h>
56
#include <ydb/core/protos/tx_columnshard.pb.h>
67

78
namespace NKikimr::NOlap {

ydb/core/tx/columnshard/engines/scheme/abstract_scheme.h

+1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
#pragma once
22

3+
#include <ydb/core/tx/columnshard/common/snapshot.h>
34
#include <ydb/core/tx/columnshard/engines/defs.h>
45
#include <ydb/core/tx/columnshard/engines/column_features.h>
56

ydb/core/tx/columnshard/engines/storage/optimizer/lbuckets/optimizer.h

+1-1
Original file line numberDiff line numberDiff line change
@@ -744,7 +744,7 @@ class TPortionsBucket: public TMoveOnly {
744744
return nullptr;
745745
}
746746
}
747-
AFL_DEBUG(NKikimrServices::TX_COLUMNSHARD)("stop_instant", stopInstant.value_or(TInstant::Zero()))("size", size)("next", NextBorder ? NextBorder->DebugString() : "")
747+
AFL_DEBUG(NKikimrServices::TX_COLUMNSHARD)("stop_instant", stopInstant)("size", size)("next", NextBorder ? NextBorder->DebugString() : "")
748748
("count", portions.size())("info", Others.DebugString())("event", "start_optimization")("stop_point", stopPoint ? stopPoint->DebugString() : "");
749749
TSaverContext saverContext(storagesManager->GetOperator(IStoragesManager::DefaultStorageId), storagesManager);
750750
auto result = std::make_shared<NCompaction::TGeneralCompactColumnEngineChanges>(limits.GetSplitSettings(), granule, portions, saverContext);

ydb/core/tx/columnshard/tables_manager.cpp

+3-1
Original file line numberDiff line numberDiff line change
@@ -270,7 +270,9 @@ void TTablesManager::AddSchemaVersion(const ui32 presetId, const NOlap::TSnapsho
270270
}
271271

272272
void TTablesManager::AddTableVersion(const ui64 pathId, const NOlap::TSnapshot& version, const TTableInfo::TTableVersionInfo& versionInfo, NIceDb::TNiceDb& db) {
273-
auto& table = Tables.at(pathId);
273+
auto it = Tables.find(pathId);
274+
AFL_VERIFY(it != Tables.end());
275+
auto& table = it->second;
274276

275277
if (versionInfo.HasSchemaPresetId()) {
276278
Y_ABORT_UNLESS(SchemaPresets.contains(versionInfo.GetSchemaPresetId()));

0 commit comments

Comments
 (0)