Browse Source

YQL-19296: BlockReader right way to determine native flag

YQL-19296: BlockReader right way to determine native flag
commit_hash:b83482702841df8fc931c2c8bc9d257fca8c3432
mrlolthe1st 2 months ago
parent
commit
138d7c2df8
1 changed files with 1 additions and 1 deletions
  1. 1 1
      yt/yql/providers/yt/comp_nodes/dq/dq_yt_block_reader.cpp

+ 1 - 1
yt/yql/providers/yt/comp_nodes/dq/dq_yt_block_reader.cpp

@@ -368,7 +368,7 @@ public:
         LocalListeners_.reserve(Inputs_.size());
         for (size_t i = 0; i < Inputs_.size(); ++i) {
             auto& decoder = Settings_->Specs->Inputs[Settings_->OriginalIndexes[i]];
-            bool native = decoder->NativeYtTypeFlags && !decoder->FieldsVec[i].ExplicitYson;
+            bool native = decoder->NativeYtTypeFlags;
             LocalListeners_.emplace_back(std::make_shared<TLocalListener>(Listener_, Settings_->ColumnNameMapping, ptr, types, *Settings_->Pool, Settings_->PgBuilder, native, jobStats));
             LocalListeners_.back()->Init(LocalListeners_.back());
         }