fix getMinimalSupportedVersion

alexklibisz · Nov 8, 2023 · 3bd4b10 · 3bd4b10
1 parent 3fe5e6c
commit 3bd4b10
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/elastiknn-plugin/src/main/scala/com/klibisz/elastiknn/query/ElasticsearchQueryBuilder.scala b/elastiknn-plugin/src/main/scala/com/klibisz/elastiknn/query/ElasticsearchQueryBuilder.scala
@@ -11,7 +11,7 @@ import org.elasticsearch.client.internal.Client
 import org.elasticsearch.common.io.stream.{StreamInput, StreamOutput, Writeable}
 import org.elasticsearch.index.query._
 import org.elasticsearch.xcontent.{ToXContent, XContentBuilder, XContentParser}
-import org.elasticsearch.{ElasticsearchException, ResourceNotFoundException, TransportVersion}
+import org.elasticsearch.{ElasticsearchException, ResourceNotFoundException, TransportVersion, TransportVersions}
 
 import java.util.Objects
 import java.util.concurrent.atomic.AtomicReference
@@ -161,6 +161,6 @@ final class ElasticsearchQueryBuilder(val query: NearestNeighborsQuery, elastikn
     queryBuilder
   }
 
-  override def getMinimalSupportedVersion: TransportVersion = TransportVersion.current()
+  override def getMinimalSupportedVersion: TransportVersion = TransportVersions.MINIMUM_COMPATIBLE
 
 }
diff --git a/...plugin/src/main/scala/com/klibisz/elastiknn/query/ElasticsearchScoreFunctionBuilder.scala b/...plugin/src/main/scala/com/klibisz/elastiknn/query/ElasticsearchScoreFunctionBuilder.scala
@@ -3,7 +3,7 @@ package com.klibisz.elastiknn.query
 import com.klibisz.elastiknn.ELASTIKNN_NAME
 import com.klibisz.elastiknn.ElastiknnException.ElastiknnUnsupportedOperationException
 import com.klibisz.elastiknn.api.{NearestNeighborsQuery, Vec}
-import org.elasticsearch.TransportVersion
+import org.elasticsearch.{TransportVersion, TransportVersions}
 import org.elasticsearch.common.io.stream.{StreamInput, StreamOutput, Writeable}
 import org.elasticsearch.common.lucene.search.function.ScoreFunction
 import org.elasticsearch.index.query.SearchExecutionContext
@@ -34,7 +34,7 @@ final class ElasticsearchScoreFunctionBuilder(
   override def doToFunction(context: SearchExecutionContext): ScoreFunction =
     elastiknnQueryBuilder.build(query, context).map(_.toScoreFunction(context.getIndexReader)).get
 
-  override def getMinimalSupportedVersion: TransportVersion = TransportVersion.current()
+  override def getMinimalSupportedVersion: TransportVersion = TransportVersions.MINIMUM_COMPATIBLE
 }
 
 object ElasticsearchScoreFunctionBuilder {