File tree Expand file tree Collapse file tree 2 files changed +11
-1
lines changed
columnshard/engines/scheme/indexes/abstract Expand file tree Collapse file tree 2 files changed +11
-1
lines changed Original file line number Diff line number Diff line change @@ -443,7 +443,12 @@ class TNormalForm {
443
443
444
444
std::shared_ptr<TDataForIndexesCheckers> TDataForIndexesCheckers::Build (const TProgramContainer& program) {
445
445
AFL_DEBUG (NKikimrServices::TX_COLUMNSHARD)(" program" , program.DebugString ());
446
- auto fStep = program.GetSteps ().front ();
446
+ auto & steps = program.GetStepsVerified ();
447
+ if (!steps.size ()) {
448
+ AFL_WARN (NKikimrServices::TX_COLUMNSHARD)(" event" , " no_steps_in_program" );
449
+ return nullptr ;
450
+ }
451
+ auto fStep = steps.front ();
447
452
TNormalForm nForm;
448
453
for (auto && s : fStep ->GetAssignes ()) {
449
454
if (!nForm.Add (s, program)) {
Original file line number Diff line number Diff line change @@ -85,6 +85,11 @@ class TProgramContainer {
85
85
}
86
86
}
87
87
88
+ const std::vector<std::shared_ptr<NSsa::TProgramStep>>& GetStepsVerified () const {
89
+ AFL_VERIFY (!!Program);
90
+ return Program->Steps ;
91
+ }
92
+
88
93
template <class TDataContainer >
89
94
inline arrow::Status ApplyProgram (std::shared_ptr<TDataContainer>& batch) const {
90
95
if (Program) {
You can’t perform that action at this time.
0 commit comments