I'm currently working on upgrading a plugin to be compatible with our new 5.4 cluster. I've been following this tutorial, which has been very helpful, however I've hit a dead end in my quest for resolution...
Here's my setup:
MyPlugin (extends Plugin and implements ScriptPlugin) - this is the main plugin class which gathers all the factories to generate new scripts. I have not seen any tutorials saying there needs to be more in this class. Score, Rating and Tag all extend AbstractSearchScript, and their respective factories implement NativeScriptFactory
@Override
public List<NativeScriptFactory> getNativeScripts() {
return Arrays.asList(new Score.Factory(),
new Rating.Factory(),
new Tag.Factory());
}
I followed all of the instructions, added the necessary Maven dependencies and implemented the ANT script from the ES5 Plugin Integration Test tutorial to get everything set and ready for testing. When I run mvn install, the test cluster spins up, and runs all of the Integration Tests I created for the scripts above. Here's an example of one of the tests:
@Test
public void runNegativeScore() throws Exception {
//Adds a non-random doc to the ES Cluster customized for this test
addImpactScoreStory(true, true, false);
//Generates script parameters
Map<String, Object> params = generateParameters(false, false);
// Retrieve first 10 prime records
SearchResponse searchResponse = client().prepareSearch("test")
.addScriptField("scores", new Script(ScriptType.FILE, "native", "Score", params))
.setQuery(matchAllQuery())
.setSize(20)
// .addSort("number", SortOrder.ASC)
.execute().actionGet();
SearchHits hits = searchResponse.getHits();
for (SearchHit hit : hits) {
if (hit.getId().equals("1")) {
double[] values = hit.getField("scores").getValue();
assert (Math.round(values[0] * 100) / 100d == -.22);
assert (Math.round(values[1] * 100) / 100d == -.22);
}
}
System.out.println(searchResponse.toString());
assertNoFailures(searchResponse);
}
When this test is run, I'm getting the following error
RemoteTransportException[[node_sm1][local[4]][indices:data/read/search[phase/dfs]]]; nested: ResourceNotFoundException[unable to find script [Score] using lang [native] in cluster state]; }
at __randomizedtesting.SeedInfo.seed([92F76D668DFB2FE9:BE6CD19FE52E4E36]:0)
at org.elasticsearch.action.search.AbstractSearchAsyncAction.onPhaseFailure(AbstractSearchAsyncAction.java:272)
at org.elasticsearch.action.search.AbstractSearchAsyncAction.executeNextPhase(AbstractSearchAsyncAction.java:130)
at org.elasticsearch.action.search.AbstractSearchAsyncAction.onPhaseDone(AbstractSearchAsyncAction.java:241)
at org.elasticsearch.action.search.InitialSearchPhase.onShardFailure(InitialSearchPhase.java:87)
at org.elasticsearch.action.search.InitialSearchPhase.access$100(InitialSearchPhase.java:47)
at org.elasticsearch.action.search.InitialSearchPhase$1.onFailure(InitialSearchPhase.java:155)
at org.elasticsearch.action.ActionListenerResponseHandler.handleException(ActionListenerResponseHandler.java:51)
at org.elasticsearch.transport.TransportService$ContextRestoreResponseHandler.handleException(TransportService.java:1050)
at org.elasticsearch.transport.local.LocalTransport.handleException(LocalTransport.java:467)
at org.elasticsearch.transport.local.LocalTransport.handleResponseError(LocalTransport.java:458)
at org.elasticsearch.transport.local.LocalTransport.processReceivedMessage(LocalTransport.java:338)
at org.elasticsearch.transport.local.LocalTransport.lambda$receiveMessage$0(LocalTransport.java:300)
at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:569)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: ResourceNotFoundException[unable to find script [Score] using lang [native] in cluster state]
at org.elasticsearch.script.ScriptService.getScriptFromClusterState(ScriptService.java:369)
at org.elasticsearch.script.ScriptService.compile(ScriptService.java:244)
at org.elasticsearch.script.ScriptService.search(ScriptService.java:490)
at org.elasticsearch.search.SearchService.parseSource(SearchService.java:684)
at org.elasticsearch.search.SearchService.createContext(SearchService.java:472)
at org.elasticsearch.search.SearchService.createAndPutContext(SearchService.java:448)
at org.elasticsearch.search.SearchService.executeDfsPhase(SearchService.java:221)
at org.elasticsearch.action.search.SearchTransportService$5.messageReceived(SearchTransportService.java:328)
at org.elasticsearch.action.search.SearchTransportService$5.messageReceived(SearchTransportService.java:325)
at org.elasticsearch.transport.RequestHandlerRegistry.processMessageReceived(RequestHandlerRegistry.java:69)
at org.elasticsearch.transport.local.LocalTransport$2.doRun(LocalTransport.java:390)
at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:638)
at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
... 3 more
Which is caused by this line (used in the 1.7 tests)
.addScriptField("scores", new Script(ScriptType.STORED, "native", "Score", params))
I've tried using ScriptType.FILE and ScriptType.INLINE as well, but neither of them worked. The test is unable to load my script, and therefore unable to properly run the tests. Is there another method I should be using to access these scripts for the tests? Please let me know if you need any more information re: my set up. Any and all suggestions are welcome 