diff --git a/geaflow/geaflow-plugins/geaflow-store/geaflow-store-vector/src/main/java/org/apache/geaflow/store/lucene/GraphVectorIndex.java b/geaflow/geaflow-plugins/geaflow-store/geaflow-store-vector/src/main/java/org/apache/geaflow/store/lucene/GraphVectorIndex.java index ed49e667c..88934d6b4 100644 --- a/geaflow/geaflow-plugins/geaflow-store/geaflow-store-vector/src/main/java/org/apache/geaflow/store/lucene/GraphVectorIndex.java +++ b/geaflow/geaflow-plugins/geaflow-store/geaflow-store-vector/src/main/java/org/apache/geaflow/store/lucene/GraphVectorIndex.java @@ -136,9 +136,7 @@ public void addVectorIndex(boolean isVertex, K key, String fieldName, float[] ve */ @Override public K searchVectorIndex(boolean isVertex, String fieldName, float[] vector, int topK) { - try { - // Open index reader - IndexReader reader = DirectoryReader.open(directory); + try (IndexReader reader = DirectoryReader.open(directory)) { IndexSearcher searcher = new IndexSearcher(reader); // Create KNN vector query @@ -166,8 +164,6 @@ public K searchVectorIndex(boolean isVertex, String fieldName, float[] vector, i throw new IllegalArgumentException("Unsupported key type: " + keyClass.getName()); } - reader.close(); - return result; } catch (IOException e) { throw new RuntimeException("Failed to search vector index", e);