Fix flight server integ test on unix machine

Signed-off-by: Rishabh Maurya <[email protected]>
rishabhmaurya · Jan 24, 2025 · 2db7f85 · 2db7f85
1 parent 8cc5556
commit 2db7f85
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ns/arrow-flight-rpc/src/main/java/org/opensearch/arrow/flight/bootstrap/ServerConfig.java b/...ns/arrow-flight-rpc/src/main/java/org/opensearch/arrow/flight/bootstrap/ServerConfig.java
@@ -186,11 +186,11 @@ static EventLoopGroup createELG(String name, int eventLoopThreads) {
     }
 
     static Class<? extends Channel> serverChannelType() {
-        return Epoll.isAvailable() ? EpollSocketChannel.class : NioServerSocketChannel.class;
+        return Epoll.isAvailable() ? EpollServerSocketChannel.class : NioServerSocketChannel.class;
     }
 
     static Class<? extends Channel> clientChannelType() {
-        return Epoll.isAvailable() ? EpollServerSocketChannel.class : NioSocketChannel.class;
+        return Epoll.isAvailable() ? EpollSocketChannel.class : NioSocketChannel.class;
     }
 
     private static class Netty4Configs {