diff --git a/flight/flight-core/pom.xml b/flight/flight-core/pom.xml index 5c6c3378c..95748702a 100644 --- a/flight/flight-core/pom.xml +++ b/flight/flight-core/pom.xml @@ -202,4 +202,41 @@ under the License. + + + + native-epoll-test + + + linux + + + + + io.netty + netty-transport-native-epoll + ${dep.netty-bom.version} + ${os.detected.classifier} + test + + + + + native-kqueue-test + + + mac + + + + + io.netty + netty-transport-native-kqueue + ${dep.netty-bom.version} + ${os.detected.classifier} + test + + + + diff --git a/flight/flight-core/src/main/java/org/apache/arrow/flight/grpc/NettyClientBuilder.java b/flight/flight-core/src/main/java/org/apache/arrow/flight/grpc/NettyClientBuilder.java index 42cdaac01..e65871121 100644 --- a/flight/flight-core/src/main/java/org/apache/arrow/flight/grpc/NettyClientBuilder.java +++ b/flight/flight-core/src/main/java/org/apache/arrow/flight/grpc/NettyClientBuilder.java @@ -19,8 +19,8 @@ import io.grpc.ManagedChannel; import io.grpc.netty.GrpcSslContexts; import io.grpc.netty.NettyChannelBuilder; +import io.netty.channel.Channel; import io.netty.channel.EventLoopGroup; -import io.netty.channel.ServerChannel; import io.netty.handler.ssl.SslContextBuilder; import io.netty.handler.ssl.util.InsecureTrustManagerFactory; import java.io.InputStream; @@ -151,7 +151,7 @@ public NettyChannelBuilder build() { // Linux builder.channelType( Class.forName("io.netty.channel.epoll.EpollDomainSocketChannel") - .asSubclass(ServerChannel.class)); + .asSubclass(Channel.class)); final EventLoopGroup elg = Class.forName("io.netty.channel.epoll.EpollEventLoopGroup") .asSubclass(EventLoopGroup.class) @@ -162,7 +162,7 @@ public NettyChannelBuilder build() { // BSD builder.channelType( Class.forName("io.netty.channel.kqueue.KQueueDomainSocketChannel") - .asSubclass(ServerChannel.class)); + .asSubclass(Channel.class)); final EventLoopGroup elg = Class.forName("io.netty.channel.kqueue.KQueueEventLoopGroup") .asSubclass(EventLoopGroup.class)