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 a235de7e2087c5..ebf379797b1acb 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 CompletableFuture process() { for (List> getRequests : splitRequests) { executor.execute( () -> { - try { - ReadOptions readOptions = new ReadOptions(); + try (ReadOptions readOptions = new ReadOptions()) { readOptions.setReadaheadSize(0); List keys = new ArrayList<>(getRequests.size()); List columnFamilyHandles =