fixes

Author: ivanmorozov333

ydb/core/tx/columnshard/columnshard_impl.cpp

@@ -1278,6 +1278,7 @@ class TTxAskPortionChunks: public TTransactionBase<TColumnShard> {
         TBlobGroupSelector selector(Self->Info());
         bool reask = false;
         for (auto&& i : PortionsByPath) {
+            AFL_INFO(NKikimrServices::TX_COLUMNSHARD)("event", "TTxAskPortionChunks::Execute")("size", i.second.size())("path_id", i.first);
             for (auto&& p : i.second) {
                 {
                     auto rowset = db.Table<NColumnShard::Schema::IndexColumnsV2>().Prefix(p->GetPathId(), p->GetPortionId()).Select();
@@ -1298,6 +1299,7 @@ class TTxAskPortionChunks: public TTransactionBase<TColumnShard> {
         }
 
         for (auto&& i : PortionsByPath) {
+            AFL_INFO(NKikimrServices::TX_COLUMNSHARD)("event", "TTxAskPortionChunks::Execute")("stage", "processing")("size", i.second.size())("path_id", i.first);
             while (i.second.size()) {
                 auto p = i.second.back();
                 std::vector<NOlap::TColumnChunkLoadContextV1> records;
@@ -1329,8 +1331,11 @@ class TTxAskPortionChunks: public TTransactionBase<TColumnShard> {
                 FetchedAccessors.emplace_back(NOlap::TPortionAccessorConstructor::BuildForLoading(p, std::move(records), std::move(indexes)));
                 i.second.pop_back();
             }
+            AFL_INFO(NKikimrServices::TX_COLUMNSHARD)("event", "TTxAskPortionChunks::Execute")("stage", "finished")("size", i.second.size())(
+                "path_id", i.first);
         }
 
+        AFL_INFO(NKikimrServices::TX_COLUMNSHARD)("event", "TTxAskPortionChunks::Execute")("stage", "finished");
         FetchCallback->OnAccessorsFetched(std::move(FetchedAccessors));
         return true;
     }
@@ -1447,7 +1452,9 @@ void TColumnShard::Enqueue(STFUNC_SIG) {
     switch (ev->GetTypeRewrite()) {
         HFunc(TEvPrivate::TEvTieringModified, Handle);
         HFunc(TEvPrivate::TEvNormalizerResult, Handle);
+        HFunc(NOlap::NDataAccessorControl::TEvAskTabletDataAccessors, Handle);
         default:
+            AFL_WARN(NKikimrServices::TX_COLUMNSHARD)("event", "unexpected event in enqueue");
             return NTabletFlatExecutor::TTabletExecutedFlat::Enqueue(ev);
     }
 }

ydb/core/tx/columnshard/data_accessor/actor.h

@@ -48,6 +48,7 @@ class TActor: public TActorBootstrapped<TActor> {
     void Bootstrap();
 
     STFUNC(StateWait) {
+        const NActors::TLogContextGuard lGuard = NActors::TLogContextBuilder::Build()("self_id", SelfId())("tablet_id", TabletId)("parent", Parent);
         switch (ev->GetTypeRewrite()) {
             cFunc(NActors::TEvents::TEvPoison::EventType, StartStopping);
             hFunc(TEvRegisterController, Handle);

ydb/core/tx/columnshard/data_accessor/manager.h

@@ -96,6 +96,7 @@ class TLocalManager: public IDataAccessorsManager {
     const std::shared_ptr<IAccessorCallback> AccessorCallback;
 
     virtual void DoAskData(const std::shared_ptr<TDataAccessorsRequest>& request) override {
+        AFL_INFO(NKikimrServices::TX_COLUMNSHARD)("event", "ask_data")("request", request->DebugString());
         for (auto&& i : request->GetPathIds()) {
             auto it = Managers.find(i);
             if (it == Managers.end()) {

ydb/core/tx/columnshard/data_accessor/request.h

@@ -117,6 +117,12 @@ class TPathFetchingState {
     THashMap<ui64, TPortionDataAccessor> PortionAccessors;
 
 public:
+    TString DebugString() const {
+        TStringBuilder sb;
+        sb << "portions_count=" << Portions.size();
+        return sb;
+    }
+
     TPathFetchingState(const ui64 pathId)
         : PathId(pathId) {
     }
@@ -191,6 +197,15 @@ class TDataAccessorsRequest: public NColumnShard::TMonitoringObjectsCounter<TDat
     }
 
 public:
+    TString DebugString() const {
+        TStringBuilder sb;
+        sb << "request_id=" << RequestId << ";";
+        for (auto&& i : PathIdStatus) {
+            sb << i.first << "={" << i.second.DebugString() << "};";
+        }
+        return sb;
+    }
+
     TDataAccessorsRequest() = default;
 
     bool HasSubscriber() const {

ydb/core/tx/columnshard/engines/storage/granule/stages.cpp

@@ -69,7 +69,6 @@ bool TGranuleFinishAccessorsLoading::DoExecute(NTabletFlatExecutor::TTransaction
 bool TGranuleFinishCommonLoading::DoExecute(NTabletFlatExecutor::TTransactionContext& /*txc*/, const TActorContext& /*ctx*/) {
     AFL_VERIFY(!Started);
     Started = true;
-    TMemoryProfileGuard g("TTxInit/LoadColumns/After");
     Self->OnAfterPortionsLoad();
     return true;
 }