Set es.set.netty.runtime.available.processors to false

akka · Sep 19, 2017 · 45d76e0 · 45d76e0
1 parent 618ebf0
commit 45d76e0
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/elasticsearch/src/test/java/akka/stream/alpakka/elasticsearch/ElasticsearchTest.java b/elasticsearch/src/test/java/akka/stream/alpakka/elasticsearch/ElasticsearchTest.java
@@ -39,8 +39,12 @@ public static class Book {
 
   @BeforeClass
   public static void setup() throws IOException {
+    System.setProperty("es.set.netty.runtime.available.processors", "false");
     runner = new ElasticsearchClusterRunner();
-    runner.build(ElasticsearchClusterRunner.newConfigs().baseHttpPort(9210).baseTransportPort(9310).numOfNode(1));
+    runner.build(ElasticsearchClusterRunner.newConfigs()
+        .baseHttpPort(9210)
+        .baseTransportPort(9310)
+        .numOfNode(1));
     runner.ensureYellow();
 
     //#init-client

diff --git a/elasticsearch/src/test/scala/akka/stream/alpakka/elasticsearch/ElasticsearchSpec.scala b/elasticsearch/src/test/scala/akka/stream/alpakka/elasticsearch/ElasticsearchSpec.scala
@@ -39,7 +39,14 @@ class ElasticsearchSpec extends WordSpec with Matchers with BeforeAndAfterAll {
   //#define-class
 
   override def beforeAll() = {
-    runner.build(ElasticsearchClusterRunner.newConfigs().baseHttpPort(9200).baseTransportPort(9300).numOfNode(1))
+    System.setProperty("es.set.netty.runtime.available.processors", "false")
+    runner.build(
+      ElasticsearchClusterRunner
+        .newConfigs()
+        .baseHttpPort(9200)
+        .baseTransportPort(9300)
+        .numOfNode(1)
+    )
     runner.ensureYellow()
 
     register("source", "Akka in Action")