max_docs_per_hop must be max_docs_per_query in the Resolution API handler.

Author: davemoore-

src/main/java/org/elasticsearch/plugin/zentity/ResolutionAction.java

@@ -259,7 +259,7 @@ protected RestChannelConsumer prepareRequest(RestRequest restRequest, NodeClient
         Boolean includeHits = restRequest.paramAsBoolean("hits", Job.DEFAULT_INCLUDE_HITS);
         Boolean includeQueries = restRequest.paramAsBoolean("queries", Job.DEFAULT_INCLUDE_QUERIES);
         Boolean includeSource = restRequest.paramAsBoolean("_source", Job.DEFAULT_INCLUDE_SOURCE);
-        int maxDocsPerQuery = restRequest.paramAsInt("max_docs_per_hop", Job.DEFAULT_MAX_DOCS_PER_QUERY);
+        int maxDocsPerQuery = restRequest.paramAsInt("max_docs_per_query", Job.DEFAULT_MAX_DOCS_PER_QUERY);
         int maxHops = restRequest.paramAsInt("max_hops", Job.DEFAULT_MAX_HOPS);
         Boolean pretty = restRequest.paramAsBoolean("pretty", Job.DEFAULT_PRETTY);
         Boolean profile = restRequest.paramAsBoolean("profile", Job.DEFAULT_PROFILE);

src/test/java/io/zentity/resolution/JobIT.java

@@ -103,7 +103,7 @@ public void testJob() throws Exception {
 
     public void testJobMaxHopsAndDocs() throws Exception {
         prepareTestResources();
-        String endpoint = "_zentity/resolution/zentity_test_entity_a?max_hops=2&max_docs_per_hop=2";
+        String endpoint = "_zentity/resolution/zentity_test_entity_a?max_hops=2&max_docs_per_query=2";
         Response response = client.performRequest("POST", endpoint, params, testJobMaxHopsAndDocsPayload);
         JsonNode json = mapper.readTree(response.getEntity().getContent());
         assertEquals(json.get("hits").get("total").asInt(), 20);