[e2e] Add query service test with deletion vectors options

apache · Oct 10, 2024 · 6c036c8 · 6c036c8
1 parent 3120722
commit 6c036c8
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/...8/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java b/...8/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java
@@ -423,6 +423,20 @@ public void testQueryService() {
                 .doesNotThrowAnyException();
     }
 
+    @Test
+    public void testQueryServiceWithDeletionVectors() {
+        sql(
+                "CREATE TABLE DIM (k INT, v STRING, PRIMARY KEY(k) NOT ENFORCED) WITH ('bucket' = '1', 'deletion-vectors.enabled' = 'true')");
+        sql("INSERT INTO DIM VALUES (1, 'a'), (2, 'b')");
+        assertThatCode(
+                        () -> {
+                            CloseableIterator<Row> service =
+                                    streamSqlIter("CALL sys.query_service('default.DIM', 1)");
+                            service.close();
+                        })
+                .doesNotThrowAnyException();
+    }
+
     @Test
     public void testRemoveOrphanFiles() {
         sql(