comment obtenir le TransportClient maquette en ElasticSearch

Question

J'utilise la version 5.6.0 ElasticSearch Je suis en train de faire MockTransportClient est le code ici

class CampaignTest extends ESTestCase { 
    def mockClient ={ 
    val clusterName = "elasticsearch" 
    val dataDir = Files.createTempDirectory("elasticsearch_data_test").toFile 
    val settings = Settings.builder() 
    .put("path.data", dataDir.toString) 
    .put("cluster.name", clusterName) 
    .build 

    val client = new MockTransportClient(settings); 
    println("got the client "+client) 
    client 
    } 
} 

class TestCampaign extends PlaySpec { 
    val campaignTest= new CampaignTest 
    val client = campaignTest.mockClient 
    info("client is "+client) 
} 

Je reçois exception lorsque je tente de lancer TestCampaign

[2017-10-06T15:51:55,191][INFO ][o.e.p.PluginsService  ] [_client_] no modules loaded 
[2017-10-06T15:51:55,206][INFO ][o.e.p.PluginsService  ] [_client_] no plugins loaded 
[info] DeferredAbortedSuite: 
[info] Exception encountered when attempting to run a suite with class name: org.scalatest.DeferredAbortedSuite *** ABORTED *** 
[info] java.lang.IllegalStateException: running tests but failed to invoke RandomizedContext#getRandom 
[info] at org.elasticsearch.common.Randomness.get(Randomness.java:105) 
[info] at org.elasticsearch.client.transport.TransportClientNodesService.<init>(TransportClientNodesService.java:100) 
[info] at org.elasticsearch.client.transport.TransportClient.buildTemplate(TransportClient.java:195) 
[info] at org.elasticsearch.client.transport.TransportClient.<init>(TransportClient.java:265) 
[info] at org.elasticsearch.transport.MockTransportClient.<init>(MockTransportClient.java:42) 
[info] at org.elasticsearch.transport.MockTransportClient.<init>(MockTransportClient.java:34) 
[info] at testcontrollers.campaign.CampaignTest.mockClient(CampaignTest.scala:34) 
[info] at testcontrollers.campaign.TestCampaign.<init>(TestCampaign.scala:13) 
[info] at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) 
[info] at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) 
[info] ... 
[info] Cause: java.lang.reflect.InvocationTargetException: 
[info] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
[info] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
[info] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
[info] at java.lang.reflect.Method.invoke(Method.java:498) 
[info] at org.elasticsearch.common.Randomness.get(Randomness.java:101) 
[info] at org.elasticsearch.client.transport.TransportClientNodesService.<init>(TransportClientNodesService.java:100) 
[info] at org.elasticsearch.client.transport.TransportClient.buildTemplate(TransportClient.java:195) 
[info] at org.elasticsearch.client.transport.TransportClient.<init>(TransportClient.java:265) 
[info] at org.elasticsearch.transport.MockTransportClient.<init>(MockTransportClient.java:42) 
[info] at org.elasticsearch.transport.MockTransportClient.<init>(MockTransportClient.java:34) 
[info] ... 
[info] Cause: java.lang.IllegalStateException: No context information for thread: Thread[id=10, name=pool-1-thread-1, state=RUNNABLE, group=main]. Is this thread running under a class com.carrotsearch.randomizedtesting.RandomizedRunner runner context? Add @RunWith(class com.carrotsearch.randomizedtesting.RandomizedRunner.class) to your test class. Make sure your code accesses random contexts within @BeforeClass and @AfterClass boundary (for example, static test class initializers are not permitted to access random contexts). 
[info] at com.carrotsearch.randomizedtesting.RandomizedContext.context(RandomizedContext.java:248) 
[info] at com.carrotsearch.randomizedtesting.RandomizedContext.current(RandomizedContext.java:134) 
[info] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
[info] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
[info] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
[info] at java.lang.reflect.Method.invoke(Method.java:498) 
[info] at org.elasticsearch.common.Randomness.get(Randomness.java:101) 
[info] at org.elasticsearch.client.transport.TransportClientNodesService.<init>(TransportClientNodesService.java:100) 
[info] at org.elasticsearch.client.transport.TransportClient.buildTemplate(TransportClient.java:195) 
[info] at org.elasticsearch.client.transport.TransportClient.<init>(TransportClient.java:265) 

et voici les dépendances dans build.sbt

"org.elasticsearch" % "elasticsearch" % "5.6.0", 
       "org.elasticsearch.client" % "transport" % "5.6.0", 
       "org.apache.lucene" % "lucene-expressions" % "6.6.0", 
       "org.apache.logging.log4j" % "log4j-core" % "2.9.0", 
       "org.apache.lucene" % "lucene-test-framework" % "6.6.0" % "test" , 
       "org.elasticsearch.test" % "framework" % "5.5.2" % "test", 

où je suis faire erreur

Answer 1

Parce que tests ElasticSearch est dépendait du randomizedtesting et doivent fonctionner avec RandomizedRunner pour injecter random context. Donc pour votre exemple, vous devriez exécuter votre test sous le contexte RandomizedRunner.

et depuis RandomizedRunner ne peut que soutenir l'exécution avec JUnit, donc pour votre test ne devrait soutenir fonctionner class CampaignTest extends ESTestCase pas PlaySpec avec JUnit, et vous pouvez écrire votre test en utilisant JUnit syntaxe, comme:

class CampaignTest extends ESTestCase { 
    var client: Client = null 


    @Before def initClient(): Unit = { 
    val file = Files.createTempDirectory("tempESData") 
    val settings = Settings.builder() 
     .put("http.enabled", "false") 
     .put("path.data", file.toString()).build() 
    client = new MockTransportClient(settings) 
    } 
    @Test def myTest(): unit = { 
    ... 
    } 

    @After def closeClient(): Unit = { 
    client.close() //close client after test 
    client = null 
    } 
}