es 9.2.3 support

Author: shi-yuan

.github/workflows/actions.yml

@@ -19,7 +19,7 @@ jobs:
 
       - name: Install Elasticsearch
         env:
-          ES_VERSION: 9.1.10
+          ES_VERSION: 9.2.3
         run: |
           sudo rm -rf /var/lib/elasticsearch
           curl -fsSL --retry 3 --retry-delay 5 "https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-${ES_VERSION}-amd64.deb" -o elasticsearch.deb

.travis.yml

@@ -6,7 +6,7 @@ jdk:
 
 before_install:
   - sudo rm -rf /var/lib/elasticsearch
-  - curl https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-9.1.10-amd64.deb -o elasticsearch.deb && sudo dpkg -i --force-confnew elasticsearch.deb
+  - curl https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-9.2.3-amd64.deb -o elasticsearch.deb && sudo dpkg -i --force-confnew elasticsearch.deb
   - sudo cp ./src/test/resources/elasticsearch.yml /etc/elasticsearch/elasticsearch.yml
   - sudo cat /etc/elasticsearch/elasticsearch.yml
   - sudo java -version

pom.xml

@@ -3,7 +3,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>org.nlpcn</groupId>
 	<artifactId>elasticsearch-sql</artifactId>
-	<version>9.1.10.0</version>
+	<version>9.2.3.0</version>
 	<packaging>jar</packaging>
 	<description>Query elasticsearch using SQL</description>
 	<name>elasticsearch-sql</name>
@@ -44,7 +44,7 @@
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<runSuite>**/MainTestSuite.class</runSuite>
 		<elasticsearch.plugin.name>sql</elasticsearch.plugin.name>
-		<elasticsearch.version>9.1.10</elasticsearch.version>
+		<elasticsearch.version>9.2.3</elasticsearch.version>
 		<elasticsearch.plugin.classname>org.elasticsearch.plugin.nlpcn.SqlPlug</elasticsearch.plugin.classname>
         <druid.version>1.2.15</druid.version>
         <guava.version>32.0.0-jre</guava.version>

src/main/java/org/elasticsearch/plugin/nlpcn/client/handler/ClusterStateActionHandler.java

@@ -146,8 +146,7 @@ protected StateRequest convertRequest(ClusterStateRequest clusterStateRequest) t
         if (clusterStateRequest.customs()) {
             builder.metric(ClusterState.Metric.CUSTOMS.toString());
         }
-        builder.local(clusterStateRequest.local());
-        Optional.ofNullable(clusterStateRequest.masterNodeTimeout()).ifPresent(e -> builder.masterTimeout(Time.of(t -> t.time(e.toString()))));
+        Optional.ofNullable(clusterStateRequest.masterTimeout()).ifPresent(e -> builder.masterTimeout(Time.of(t -> t.time(e.toString()))));
         Optional.ofNullable(clusterStateRequest.waitForTimeout()).ifPresent(e -> builder.waitForTimeout(Time.of(t -> t.time(e.toString()))));
         builder.waitForMetadataVersion(clusterStateRequest.waitForMetadataVersion());
         Optional.ofNullable(clusterStateRequest.indicesOptions()).ifPresent(options -> {

src/main/java/org/elasticsearch/plugin/nlpcn/client/handler/NodesInfoActionHandler.java

@@ -23,7 +23,6 @@
 import org.elasticsearch.common.transport.TransportAddress;
 import org.elasticsearch.common.unit.ByteSizeValue;
 import org.elasticsearch.common.unit.Processors;
-import org.elasticsearch.common.unit.SizeValue;
 import org.elasticsearch.core.TimeValue;
 import org.elasticsearch.http.HttpInfo;
 import org.elasticsearch.index.IndexVersion;
@@ -131,7 +130,7 @@ protected NodesInfoResponse convertResponse(co.elastic.clients.elasticsearch.nod
                                 Optional.ofNullable(threadPoolInfo.core()).orElse(-1),
                                 Optional.ofNullable(threadPoolInfo.max()).orElse(-1),
                                 Objects.nonNull(keepAlive) ? TimeValue.parseTimeValue(keepAlive.time(), KEY_KEEP_ALIVE) : null,
-                                threadPoolInfo.queueSize() >= 0 ? SizeValue.parseSizeValue(String.valueOf(threadPoolInfo.queueSize())) : null));
+                                (long) threadPoolInfo.queueSize()));
                     }
                     threadPool = new ThreadPoolInfo(infos);
                 }