Skip to content

Commit bd51110

Browse files
committed
es 5.6.5 support
1 parent 8815e41 commit bd51110

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

pom.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44

55
<groupId>org.ansj</groupId>
66
<artifactId>elasticsearch-analysis-ansj</artifactId>
7-
<version>5.6.4.0</version>
7+
<version>5.6.5.0</version>
88
<description>elasticsearch analysis by ansj</description>
99
<name>elasticsearch-analysis-ansj</name>
1010
<url>http://maven.nlpcn.org</url>
@@ -23,7 +23,7 @@
2323
<elasticsearch.plugin.site>true</elasticsearch.plugin.site>
2424
<elasticsearch.plugin.jvm>true</elasticsearch.plugin.jvm>
2525
<elasticsearch.plugin.java.version>1.8</elasticsearch.plugin.java.version>
26-
<elasticsearch.version>5.6.4</elasticsearch.version>
26+
<elasticsearch.version>5.6.5</elasticsearch.version>
2727
<elasticsearch.plugin.classname>org.ansj.elasticsearch.plugin.AnalysisAnsjPlugin</elasticsearch.plugin.classname>
2828
</properties>
2929

src/main/java/org/ansj/elasticsearch/action/TransportAnsjAction.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -247,15 +247,15 @@ public AnsjResponse newInstance() {
247247
@Override
248248
public void handleResponse(AnsjResponse response) {
249249
LOG.info("[{}] response: {}", node, response.asMap());
250-
countDownLatch.countDown();
251250
result.put(node.getAddress().toString(), "success");
251+
countDownLatch.countDown();
252252
}
253253

254254
@Override
255255
public void handleException(TransportException exp) {
256256
LOG.warn("failed to send request[path:{},args:{}] to [{}]: {}", req.getPath(), req.asMap(), node, exp);
257-
countDownLatch.countDown();
258257
result.put(node.getAddress().toString(), "err :" + exp.getMessage());
258+
countDownLatch.countDown();
259259
}
260260

261261
@Override

0 commit comments

Comments
 (0)