Run table service as a bookkeeper lifecycle component in bookie server

apache · Jul 22, 2023 · 564e315 · 564e315
1 parent 6f17630
commit 564e315
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 4 deletions.
diff --git a/stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/StreamCluster.java b/stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/StreamCluster.java
@@ -191,7 +191,8 @@ private LifecycleComponent startServer() throws Exception {
                 server.start();
                 log.info("Started storage server at (bookie port = {}, grpc port = {})",
                     bookiePort, grpcPort);
-                this.rpcEndpoints.add(StorageServer.createLocalEndpoint(serverConf.getAdvertisedAddress(), grpcPort, false));
+                this.rpcEndpoints.add(
+                        StorageServer.createLocalEndpoint(serverConf.getAdvertisedAddress(), grpcPort, false));
                 return server;
             } catch (Throwable e) {
                 log.error("Failed to start storage server", e);

diff --git a/stream/server/src/main/java/org/apache/bookkeeper/stream/server/StorageServer.java b/stream/server/src/main/java/org/apache/bookkeeper/stream/server/StorageServer.java
@@ -117,7 +117,8 @@ private static void loadConfFile(CompositeConfiguration conf, String confFile)
         log.info("Loaded configuration file {}", confFile);
     }
 
-    public static Endpoint createLocalEndpoint(String advertisedAddress, int port, boolean useHostname) throws UnknownHostException {
+    public static Endpoint createLocalEndpoint(String advertisedAddress, int port, boolean useHostname)
+        throws UnknownHostException {
         String hostname;
         log.warn("Determining hostname for stream storage");
         if (useHostname) {

diff --git a/...er/src/main/java/org/apache/bookkeeper/stream/server/StreamStorageLifecycleComponent.java b/...er/src/main/java/org/apache/bookkeeper/stream/server/StreamStorageLifecycleComponent.java
@@ -18,6 +18,8 @@
 
 package org.apache.bookkeeper.stream.server;
 
+import static com.google.common.base.Preconditions.checkArgument;
+
 import org.apache.bookkeeper.common.component.LifecycleComponent;
 import org.apache.bookkeeper.common.net.ServiceURI;
 import org.apache.bookkeeper.server.component.ServerLifecycleComponent;
@@ -27,8 +29,6 @@
 import org.apache.bookkeeper.stream.storage.impl.cluster.ZkClusterInitializer;
 import org.apache.commons.lang3.StringUtils;
 
-import static com.google.common.base.Preconditions.checkArgument;
-
 /**
  * This is a {@link ServerLifecycleComponent} to allow run stream storage component as part of bookie server.
  */