fix itcase

JNSimba · Jul 15, 2024 · 280b593 · 280b593
1 parent 7ec26f4
commit 280b593
Showing 1 changed file with 3 additions and 2 deletions.
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
@@ -255,15 +255,16 @@ 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()) {
             while (iterator.hasNext()) {
                 actual.add(iterator.next().toString());
             }
         }
-        String[] expected = new String[] {"+I[18]", "+I[10]"};
+        String[] expected = new String[] {"+I[18]"};
         Assert.assertArrayEquals(expected, actual.toArray());
     }