database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](autoinc) avoid duplicated auto inc when role of fe changes (#36961)

Browse Source 
## Proposed changes

pick #36960 

Issue Number: close #xxx

<!--Describe your changes.-->
This commit is contained in:
Yongqiang YANG
2024-06-28 16:54:48 +08:00
committed by GitHub
parent b46c86f352
commit 72de9c1b8f
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
fe/fe-core/src/main/java/org/apache/doris/catalog/AutoIncrementGenerator.java
View File

@ -23,6 +23,7 @@ import org.apache.doris.common.io.Text;
import org.apache.doris.common.io.Writable;
import org.apache.doris.persist.AutoIncrementIdUpdateLog;
import org.apache.doris.persist.EditLog;
import org.apache.doris.persist.gson.GsonPostProcessable;
import org.apache.doris.persist.gson.GsonUtils;
import com.google.common.base.Preconditions;
@ -34,7 +35,7 @@ import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
public class AutoIncrementGenerator implements Writable {
public class AutoIncrementGenerator implements Writable, GsonPostProcessable {
private static final Logger LOG = LogManager.getLogger(AutoIncrementGenerator.class);
public static final long NEXT_ID_INIT_VALUE = 1;
@ -102,4 +103,10 @@ public class AutoIncrementGenerator implements Writable {
public static AutoIncrementGenerator read(DataInput in) throws IOException {
return GsonUtils.GSON.fromJson(Text.readString(in), AutoIncrementGenerator.class);
}
@Override
public void gsonPostProcess() throws IOException {
nextId = batchEndId;
}
}