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(