(flink) branch master updated: [hotfix][test] Remove redundant keywords and lines for ForStGeneralMultiGetOperationTest.java (#26481)

[kunni]

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

kunni 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 9d97eef879f [hotfix][test] Remove redundant keywords and lines for 
ForStGeneralMultiGetOperationTest.java (#26481)
9d97eef879f is described below

commit 9d97eef879f11aedbd83e75bba5050c00a76bf7a
Author: Yuepeng Pan <panyuep...@apache.org>
AuthorDate: Tue May 13 19:38:43 2025 +0800

    [hotfix][test] Remove redundant keywords and lines for 
ForStGeneralMultiGetOperationTest.java (#26481)
---
 .../flink/state/forst/ForStGeneralMultiGetOperationTest.java  | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git 
a/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperationTest.java
 
b/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperationTest.java
index 2585691f43e..4f2ee7ab041 100644
--- 
a/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperationTest.java
+++ 
b/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperationTest.java
@@ -33,10 +33,10 @@ import java.util.concurrent.Executors;
 import static org.assertj.core.api.Assertions.assertThat;
 
 /** Unit test for {@link ForStGeneralMultiGetOperation}. */
-public class ForStGeneralMultiGetOperationTest extends 
ForStDBOperationTestBase {
+class ForStGeneralMultiGetOperationTest extends ForStDBOperationTestBase {
 
     @Test
-    public void testValueStateMultiGet() throws Exception {
+    void testValueStateMultiGet() throws Exception {
         ForStValueState<Integer, VoidNamespace, String> valueState1 =
                 buildForStValueState("test-multiGet-1");
         ForStValueState<Integer, VoidNamespace, String> valueState2 =
@@ -76,7 +76,7 @@ public class ForStGeneralMultiGetOperationTest extends 
ForStDBOperationTestBase
     }
 
     @Test
-    public void testListStateMultiGet() throws Exception {
+    void testListStateMultiGet() throws Exception {
         ForStListState<Integer, VoidNamespace, String> listState1 =
                 buildForStListState("test-multiGet-1");
         ForStListState<Integer, VoidNamespace, String> listState2 =
@@ -99,9 +99,6 @@ public class ForStGeneralMultiGetOperationTest extends 
ForStDBOperationTestBase
             value.add(String.valueOf(i + 1));
 
             resultCheckList.add(Tuple2.of(value, future));
-            if (value == null) {
-                continue;
-            }
             byte[] keyBytes = request.buildSerializedKey();
             byte[] valueBytes = table.serializeValue(value);
             db.put(request.getColumnFamilyHandle(), keyBytes, valueBytes);
@@ -120,7 +117,7 @@ public class ForStGeneralMultiGetOperationTest extends 
ForStDBOperationTestBase
                             (e) -> {
                                 assertThat(expected.remove(e)).isTrue();
                             });
-            assertThat(expected.isEmpty()).isTrue();
+            assertThat(expected).isEmpty();
         }
         executor.shutdownNow();
     }