diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java
index b1b6238e4..226ad8c05 100644
--- a/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java
+++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java
@@ -255,7 +255,8 @@ public void testTableSourceFilterAndProjectionPushDown() throws Exception {
                         USERNAME,
                         PASSWORD);
         tEnv.executeSql(sourceDDL);
-        TableResult tableResult = tEnv.executeSql("SELECT age FROM doris_source");
+        TableResult tableResult =
+                tEnv.executeSql("SELECT age FROM doris_source where name = 'doris'");
 
         List<String> actual = new ArrayList<>();
         try (CloseableIterator<Row> iterator = tableResult.collect()) {
@@ -263,7 +264,7 @@ public void testTableSourceFilterAndProjectionPushDown() throws Exception {
                 actual.add(iterator.next().toString());
             }
         }
-        String[] expected = new String[] {"+I[18]", "+I[10]"};
+        String[] expected = new String[] {"+I[18]"};
         Assert.assertArrayEquals(expected, actual.toArray());
     }