Skip to content

Commit ca027a1

Browse files
committed
support coordinator epoch
1 parent 4451f9f commit ca027a1

File tree

3 files changed

+0
-4
lines changed

3 files changed

+0
-4
lines changed

fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorLeaderElection.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,6 @@ private void relinquishLeadership() {
128128
try {
129129
leaderLatch.close();
130130
server.closeAsync();
131-
leaderLatch.start();
132131
} catch (Exception e) {
133132
}
134133
}

fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorServer.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,9 +55,7 @@
5555
import java.util.ArrayList;
5656
import java.util.Collection;
5757
import java.util.List;
58-
import java.util.Map;
5958
import java.util.Optional;
60-
import java.util.UUID;
6159
import java.util.concurrent.CompletableFuture;
6260
import java.util.concurrent.ExecutorService;
6361
import java.util.concurrent.Executors;

fluss-server/src/main/java/org/apache/fluss/server/zk/ZooKeeperClient.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,6 @@
5656
import org.apache.fluss.server.zk.data.ZkData.BucketSnapshotIdZNode;
5757
import org.apache.fluss.server.zk.data.ZkData.BucketSnapshotsZNode;
5858
import org.apache.fluss.server.zk.data.ZkData.ConfigEntityZNode;
59-
import org.apache.fluss.server.zk.data.ZkData.CoordinatorZNode;
6059
import org.apache.fluss.server.zk.data.ZkData.DatabaseZNode;
6160
import org.apache.fluss.server.zk.data.ZkData.DatabasesZNode;
6261
import org.apache.fluss.server.zk.data.ZkData.LakeTableZNode;

0 commit comments

Comments
 (0)