Temporary comment because of bug

FrankChen021 · Aug 15, 2024 · c66052b · c66052b
1 parent fc84df7
commit c66052b
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/server/collector/src/main/java/org/bithon/server/collector/brpc/BrpcCollectorServer.java b/server/collector/src/main/java/org/bithon/server/collector/brpc/BrpcCollectorServer.java
@@ -20,14 +20,10 @@
 import lombok.extern.slf4j.Slf4j;
 import org.bithon.component.brpc.channel.BrpcServer;
 import org.bithon.component.brpc.channel.BrpcServerBuilder;
-import org.bithon.component.commons.concurrency.NamedThreadFactory;
 import org.springframework.stereotype.Component;
 
 import java.util.HashMap;
 import java.util.Map;
-import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
 
 /**
  * @author [email protected]
@@ -56,13 +52,16 @@ public synchronized ServiceGroup addService(String group, Object implementation,
             // Create a server with the first service name as the server id
             serviceGroup.brpcServer = BrpcServerBuilder.builder()
                                                        .serverId(group)
+                                                       /*
                                                        .executor(new ThreadPoolExecutor(1,
                                                                                         Runtime.getRuntime().availableProcessors(),
                                                                                         3,
                                                                                         TimeUnit.MINUTES,
                                                                                         new LinkedBlockingQueue<>(1024),
                                                                                         NamedThreadFactory.of("brpc-executor-" + group),
                                                                                         new ThreadPoolExecutor.CallerRunsPolicy()))
+                                                        */
+                                                       .executor(Runnable::run)
                                                        .build();
             serviceGroup.start(port);
             log.info("Started Brpc services [{}] at port {}",