logging deserialization control (#16870)

Author: ivanmorozov333

ydb/core/formats/arrow/accessor/composite_serial/accessor.cpp

@@ -2,6 +2,7 @@
 
 #include <ydb/core/formats/arrow/accessor/sparsed/constructor.h>
 
+#include <ydb/library/actors/core/log.h>
 #include <ydb/library/actors/prof/tag.h>
 
 namespace NKikimr::NArrow::NAccessor {
@@ -11,6 +12,10 @@ IChunkedArray::TLocalChunkedArrayAddress TDeserializeChunkedArray::DoGetLocalChu
     if (PredefinedArray) {
         return TLocalChunkedArrayAddress(PredefinedArray, 0, 0);
     }
+    if (Counter.Inc() > 1) {
+        AFL_WARN(NKikimrServices::ARROW_HELPER)("event", "many_deserializations")("counter", Counter.Val())("size", Data.size())(
+            "buffer", DataBuffer.size());
+    }
     if (!!Data) {
         return TLocalChunkedArrayAddress(Loader->ApplyVerified(Data, GetRecordsCount()), 0, 0);
     } else {

ydb/core/formats/arrow/accessor/composite_serial/accessor.h

@@ -13,6 +13,7 @@ class TDeserializeChunkedArray: public IChunkedArray {
     const TString Data;
     const TStringBuf DataBuffer;
     const bool ForLazyInitialization;
+    mutable TAtomicCounter Counter = 0;
 
 protected:
     virtual std::shared_ptr<IChunkedArray> DoISlice(const ui32 offset, const ui32 count) const override {