remove system property value set numDirectArenas

Signed-off-by: Rishabh Maurya <[email protected]>

Author: rishabhmaurya

CHANGELOG-3.0.md

@@ -17,7 +17,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 - Added pull-based Ingestion (APIs, for ingestion source, a Kafka plugin, and IngestionEngine that pulls data from the ingestion source) ([#16958](https://github.com/opensearch-project/OpenSearch/pull/16958))
 - Added ConfigurationUtils to core for the ease of configuration parsing [#17223](https://github.com/opensearch-project/OpenSearch/pull/17223)
 - Add execution_hint to cardinality aggregator request (#[17312](https://github.com/opensearch-project/OpenSearch/pull/17312))
-- Arrow Flight RPC plugin with Flight server bootstrap logic and client for internode communication support ([#16962](https://github.com/opensearch-project/OpenSearch/pull/16962))
+- Arrow Flight RPC plugin with Flight server bootstrap logic and client for internode communication ([#16962](https://github.com/opensearch-project/OpenSearch/pull/16962))
 
 ### Dependencies
 - Update Apache Lucene to 10.1.0 ([#16366](https://github.com/opensearch-project/OpenSearch/pull/16366))

plugins/arrow-flight-rpc/build.gradle

@@ -77,12 +77,14 @@ tasks.named('test').configure {
 }
 
 test {
+  systemProperty 'io.netty.allocator.numDirectArenas', '1'
   systemProperty 'io.netty.noUnsafe', 'false'
   systemProperty 'io.netty.tryUnsafe', 'true'
   systemProperty 'io.netty.tryReflectionSetAccessible', 'true'
 }
 
 internalClusterTest {
+  systemProperty 'io.netty.allocator.numDirectArenas', '1'
   systemProperty 'io.netty.noUnsafe', 'false'
   systemProperty 'io.netty.tryUnsafe', 'true'
   systemProperty 'io.netty.tryReflectionSetAccessible', 'true'

plugins/arrow-flight-rpc/src/main/java/org/opensearch/arrow/flight/bootstrap/ServerConfig.java

@@ -12,6 +12,7 @@
 import org.opensearch.common.settings.Setting;
 import org.opensearch.common.settings.Settings;
 import org.opensearch.common.unit.TimeValue;
+import org.opensearch.common.util.concurrent.OpenSearchExecutors;
 import org.opensearch.threadpool.ScalingExecutorBuilder;
 
 import java.security.AccessController;
@@ -29,7 +30,6 @@
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
 import io.netty.channel.socket.nio.NioSocketChannel;
-import io.netty.util.concurrent.DefaultThreadFactory;
 
 /**
  * Configuration class for OpenSearch Flight server settings.
@@ -172,18 +172,14 @@ public static List<Setting<?>> getSettings() {
                 ARROW_ENABLE_UNSAFE_MEMORY_ACCESS,
                 ARROW_SSL_ENABLE
             )
-        ) {
-            {
-                addAll(Netty4Configs.getSettings());
-            }
-        };
+        );
     }
 
     static EventLoopGroup createELG(String name, int eventLoopThreads) {
 
         return Epoll.isAvailable()
-            ? new EpollEventLoopGroup(eventLoopThreads, new DefaultThreadFactory(name, true))
-            : new NioEventLoopGroup(eventLoopThreads, new DefaultThreadFactory(name, true));
+            ? new EpollEventLoopGroup(eventLoopThreads, OpenSearchExecutors.daemonThreadFactory(name))
+            : new NioEventLoopGroup(eventLoopThreads, OpenSearchExecutors.daemonThreadFactory(name));
     }
 
     static Class<? extends Channel> serverChannelType() {
@@ -195,16 +191,10 @@ static Class<? extends Channel> clientChannelType() {
     }
 
     private static class Netty4Configs {
-        public static final Setting<Integer> NETTY_ALLOCATOR_NUM_DIRECT_ARENAS = Setting.intSetting(
-            "io.netty.allocator.numDirectArenas",
-            1, // TODO - 2 * the number of available processors; to be confirmed and set after running benchmarks
-            1,
-            Setting.Property.NodeScope
-        );
 
         @SuppressForbidden(reason = "required for netty allocator configuration")
         public static void init(Settings settings) {
-            System.setProperty("io.netty.allocator.numDirectArenas", Integer.toString(NETTY_ALLOCATOR_NUM_DIRECT_ARENAS.get(settings)));
+            checkSystemProperty("io.netty.allocator.numDirectArenas", "1");
             checkSystemProperty("io.netty.noUnsafe", "false");
             checkSystemProperty("io.netty.tryUnsafe", "true");
             checkSystemProperty("io.netty.tryReflectionSetAccessible", "true");
@@ -224,9 +214,5 @@ private static void checkSystemProperty(String propertyName, String expectedValu
                 );
             }
         }
-
-        public static List<Setting<?>> getSettings() {
-            return List.of(NETTY_ALLOCATOR_NUM_DIRECT_ARENAS);
-        }
     }
 }