(flink) branch master updated: [FLINK-40327][state/forst] Close ReadOptions in ForStGeneralMultiGetOperation to fix native memory leak (#28985)

[zakelly]

This is an automated email from the ASF dual-hosted git repository.

Zakelly pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 0edbffc538a [FLINK-40327][state/forst] Close ReadOptions in 
ForStGeneralMultiGetOperation to fix native memory leak (#28985)
0edbffc538a is described below

commit 0edbffc538a15ac454d7ec50a2b5d56773c12a9f
Author: YordanPavlov <y.d.pav...@gmail.com>
AuthorDate: Thu Oct 8 16:38:29 2026 +0300

    [FLINK-40327][state/forst] Close ReadOptions in 
ForStGeneralMultiGetOperation to fix native memory leak (#28985)
---
 .../org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java
 
b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java
index a235de7e208..ebf379797b1 100644
--- 
a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java
+++ 
b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java
@@ -80,8 +80,7 @@ public class ForStGeneralMultiGetOperation implements 
ForStDBOperation {
         for (List<ForStDBGetRequest<?, ?, ?, ?>> getRequests : splitRequests) {
             executor.execute(
                     () -> {
-                        try {
-                            ReadOptions readOptions = new ReadOptions();
+                        try (ReadOptions readOptions = new ReadOptions()) {
                             readOptions.setReadaheadSize(0);
                             List<byte[]> keys = new 
ArrayList<>(getRequests.size());
                             List<ColumnFamilyHandle> columnFamilyHandles =