@@ -388,7 +388,7 @@ bool Compact(TColumnEngineForLogs& engine, TTestDbWrapper& db, TSnapshot snap, N
388
388
auto request = changes->ExtractDataAccessorsRequest ();
389
389
request->RegisterSubscriber (
390
390
std::make_shared<TTestCompactionAccessorsSubscriber>(changes, std::make_shared<NOlap::TVersionedIndex>(engine.GetVersionedIndex ())));
391
- engine.FetchDataAccessors (changes-> ExtractDataAccessorsRequest () );
391
+ engine.FetchDataAccessors (request );
392
392
}
393
393
changes->Blobs = std::move (blobs);
394
394
NOlap::TConstructionContext context (engine.GetVersionedIndex (), NColumnShard::TIndexationCounters (" Compaction" ), NOlap::TSnapshot (step, 1 ));
@@ -478,7 +478,7 @@ bool Ttl(TColumnEngineForLogs& engine, TTestDbWrapper& db, const THashMap<TInter
478
478
auto request = changes->ExtractDataAccessorsRequest ();
479
479
request->RegisterSubscriber (
480
480
std::make_shared<TTestCompactionAccessorsSubscriber>(changes, std::make_shared<NOlap::TVersionedIndex>(engine.GetVersionedIndex ())));
481
- engine.FetchDataAccessors (changes-> ExtractDataAccessorsRequest () );
481
+ engine.FetchDataAccessors (request );
482
482
}
483
483
const bool result = engine.ApplyChangesOnTxCreate (changes, TSnapshot (1 , 1 )) && engine.ApplyChangesOnExecute (db, changes, TSnapshot (1 , 1 ));
484
484
NOlap::TWriteIndexContext contextExecute (nullptr , db, engine, TSnapshot (1 , 1 ));
0 commit comments