From 6c036c8fcfbae7ab535f7b405f03b32ab8efb3d6 Mon Sep 17 00:00:00 2001
From: Shadowell <shadowell@126.com>
Date: Thu, 10 Oct 2024 10:06:15 +0800
Subject: [PATCH] [e2e] Add query service test with deletion vectors options

---
 .../ProcedurePositionalArgumentsITCase.java        | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java b/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java
index da2eaef0bd49..21f5cafc3fe5 100644
--- a/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java
+++ b/paimon-flink/paimon-flink-1.18/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(