add ff for write_id column writing

ivanmorozov333 · ivanmorozov333 · commit a3c7aead061b · 2024-09-23T07:49:50.000+03:00
diff --git a/ydb/core/tx/columnshard/engines/changes/compaction/merger.cpp b/ydb/core/tx/columnshard/engines/changes/compaction/merger.cpp
@@ -76,7 +76,8 @@ std::vector<TWritePortionInfoWithBlobsResult> TMerger::Execute(const std::shared
     TMergingContext mergingContext(batchResults, Batches);
 
     for (auto&& [columnId, columnData] : columnsData) {
-        if (columnId == (ui32)IIndexInfo::ESpecialColumn::WRITE_ID) {
+        if (columnId == (ui32)IIndexInfo::ESpecialColumn::WRITE_ID &&
+            (!HasAppData() || !AppDataVerified().FeatureFlags.GetEnableInsertWriteIdSpecialColumnCompatibility())) {
             continue;
         }
         const TString& columnName = resultFiltered->GetIndexInfo().GetColumnName(columnId);

Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,8 @@ std::vector<TWritePortionInfoWithBlobsResult> TMerger::Execute(const std::shared`
`76`	`76`	`TMergingContext mergingContext(batchResults, Batches);`
`77`	`77`
`78`	`78`	`for (auto&& [columnId, columnData] : columnsData) {`
`79`		`- if (columnId == (ui32)IIndexInfo::ESpecialColumn::WRITE_ID) {`
	`79`	`+ if (columnId == (ui32)IIndexInfo::ESpecialColumn::WRITE_ID &&`
	`80`	`+ (!HasAppData() \|\| !AppDataVerified().FeatureFlags.GetEnableInsertWriteIdSpecialColumnCompatibility())) {`
`80`	`81`	`continue;`
`81`	`82`	`}`
`82`	`83`	`const TString& columnName = resultFiltered->GetIndexInfo().GetColumnName(columnId);`