try to fix

Author: zvonand

src/Storages/ObjectStorage/DataLakes/Iceberg/AvroForIcebergDeserializer.cpp

@@ -83,6 +83,8 @@ TypeIndex AvroForIcebergDeserializer::getTypeForPath(const std::string & path) c
 
 Field AvroForIcebergDeserializer::getValueFromRowByName(size_t row_num, const std::string & path, std::optional<TypeIndex> expected_type) const
 {
+    std::lock_guard<std::mutex> lock(access_mutex);
+
     auto current_column = parsed_column_data_type->getSubcolumn(path, parsed_column);
     auto current_data_type = parsed_column_data_type->getSubcolumnType(path);
 
@@ -128,6 +130,8 @@ String removeAllSlashes(const String & input)
 
 String AvroForIcebergDeserializer::getContent(size_t row_number) const
 {
+    std::lock_guard<std::mutex> lock(access_mutex);
+
     WriteBufferFromOwnString buf;
     FormatSettings settings;
     settings.write_statistics = false;

src/Storages/ObjectStorage/DataLakes/Iceberg/AvroForIcebergDeserializer.h

@@ -10,6 +10,7 @@
 #include <Core/Field.h>
 
 #include <memory>
+#include <mutex>
 
 namespace DB::Iceberg
 {
@@ -33,6 +34,8 @@ class AvroForIcebergDeserializer
     std::shared_ptr<const DB::DataTypeTuple> parsed_column_data_type;
 
     std::map<std::string, std::vector<uint8_t>> metadata;
+
+    mutable std::mutex access_mutex;
 public:
 
     AvroForIcebergDeserializer(