Skip to content

Commit 29545c3

Browse files
LiebingYuvamossagar12
authored andcommitted
[server] Skip batch sequence validation during writer state rebuilding (apache#2188)
1 parent 5a557e2 commit 29545c3

File tree

2 files changed

+373
-1
lines changed

2 files changed

+373
-1
lines changed

fluss-server/src/main/java/org/apache/fluss/server/log/LogTablet.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1277,7 +1277,7 @@ private static void loadWritersFromRecords(
12771277
Map<Long, WriterAppendInfo> loadedWriters = new HashMap<>();
12781278
for (LogRecordBatch batch : records.batches()) {
12791279
if (batch.hasWriterId()) {
1280-
updateWriterAppendInfo(writerStateManager, batch, loadedWriters, true);
1280+
updateWriterAppendInfo(writerStateManager, batch, loadedWriters, false);
12811281
}
12821282
}
12831283
loadedWriters.values().forEach(writerStateManager::update);

0 commit comments

Comments
 (0)