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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new b6b552da4c [test] Add json itcase 
BatchFileStoreITCase.testJsonFileFormat
b6b552da4c is described below

commit b6b552da4ce55b648f07124228193c97220ff870
Author: JingsongLi <[email protected]>
AuthorDate: Thu Aug 21 10:15:58 2025 +0800

    [test] Add json itcase BatchFileStoreITCase.testJsonFileFormat
---
 .../test/java/org/apache/paimon/flink/BatchFileStoreITCase.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java
index 82b81d995d..44c7ebc754 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BatchFileStoreITCase.java
@@ -71,6 +71,13 @@ public class BatchFileStoreITCase extends CatalogITCaseBase {
         assertThat(sql("SELECT * FROM CSV")).containsExactly(Row.of(1, 2, 3));
     }
 
+    @Test
+    public void testJsonFileFormat() {
+        sql("CREATE TABLE JSON_T (a INT, b INT, c INT) WITH 
('file.format'='json')");
+        sql("INSERT INTO JSON_T VALUES (1, 2, 3)");
+        assertThat(sql("SELECT * FROM JSON_T")).containsExactly(Row.of(1, 2, 
3));
+    }
+
     @Test
     public void testFullCompactionNoDv() throws Catalog.TableNotExistException 
{
         sql(

Reply via email to