Skip to content

Commit de8a015

Browse files
authored
[hotfix] Fix the typo in comments (alibaba#202)
1 parent c770262 commit de8a015

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

fluss-server/src/main/java/com/alibaba/fluss/server/kv/KvTablet.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -409,7 +409,7 @@ public void flush(long exclusiveUpToLogOffset, FatalErrorHandler fatalErrorHandl
409409
kvLock,
410410
() -> {
411411
// when kv manager is closed which means kv tablet is already closed,
412-
// but the tablet server may still handles fetch log request from follower
412+
// but the tablet server may still handle fetch log request from follower
413413
// as the tablet rpc service is closed asynchronously, then update the watermark
414414
// and then flush the pre-write buffer.
415415

fluss-server/src/main/java/com/alibaba/fluss/server/replica/Replica.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -488,7 +488,7 @@ public void checkProjection(@Nullable int[] projectedFields) {
488488
private void onBecomeNewLeader() {
489489
if (isKvTable()) {
490490
// if it's become new leader, we must
491-
// fist destroy the old kv tablet
491+
// first destroy the old kv tablet
492492
// if exist. Otherwise, it'll use still the old kv tablet which will cause data loss
493493
dropKv();
494494
// now, we can create a new kv tablet

0 commit comments

Comments
 (0)