[fix](bloom filter)Fix rename column with bloom filter (#38431) (#38662)

backport #38431
This commit is contained in:
qiye
2024-08-01 19:01:14 +08:00
committed by GitHub
parent 2562cf33a7
commit 555dccb1a4
2 changed files with 157 additions and 0 deletions

View File

@ -310,6 +310,7 @@ import java.util.ArrayList;
import java.util.Collection;
import java.util.Comparator;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
@ -4879,6 +4880,20 @@ public class Env {
table.setSequenceMapCol(newColName);
}
// 6. modify bloom filter col
Set<String> bfCols = table.getCopiedBfColumns();
if (bfCols != null) {
Set<String> newBfCols = new HashSet<>();
for (String bfCol : bfCols) {
if (bfCol.equalsIgnoreCase(colName)) {
newBfCols.add(newColName);
} else {
newBfCols.add(bfCol);
}
}
table.setBloomFilterInfo(newBfCols, table.getBfFpp());
}
table.rebuildFullSchema();
if (!isReplay) {