From 6f8db049ffe04ebc755b78fb013e8c497639e80b Mon Sep 17 00:00:00 2001 From: weimingdiit Date: Thu, 6 Aug 2026 12:55:00 +0800 Subject: [PATCH 1/2] [AURON #2449] Add fallback coverage for unsupported Paimon scan data types Signed-off-by: weimingdiit --- .../paimon/AuronPaimonV2IntegrationSuite.scala | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/thirdparty/auron-paimon/src/test/scala/org/apache/auron/paimon/AuronPaimonV2IntegrationSuite.scala b/thirdparty/auron-paimon/src/test/scala/org/apache/auron/paimon/AuronPaimonV2IntegrationSuite.scala index a36b06441..41d8fbdc9 100644 --- a/thirdparty/auron-paimon/src/test/scala/org/apache/auron/paimon/AuronPaimonV2IntegrationSuite.scala +++ b/thirdparty/auron-paimon/src/test/scala/org/apache/auron/paimon/AuronPaimonV2IntegrationSuite.scala @@ -404,6 +404,20 @@ class AuronPaimonV2IntegrationSuite } } + test("paimon v2 native scan falls back for unsupported data types") { + withTable("paimon.db.t_unsupported_type") { + sql("create table paimon.db.t_unsupported_type (id int, amount decimal(38, 10)) using paimon") + sql( + "insert into paimon.db.t_unsupported_type values " + + "(1, cast(123.45 as decimal(38, 10)))") + + val df = sql("select * from paimon.db.t_unsupported_type") + checkAnswer(df, Seq(Row(1, new java.math.BigDecimal("123.4500000000")))) + val plan = df.queryExecution.executedPlan.toString() + assert(!plan.contains("NativePaimonV2TableScan")) + } + } + private def assertNativePaimonScanApplied(df: DataFrame): Unit = { val plan = df.queryExecution.executedPlan.toString() assert( From 4f0771f900e4680763e6e4bb57e82182dbd78515 Mon Sep 17 00:00:00 2001 From: weimingdiit Date: Thu, 6 Aug 2026 14:53:39 +0800 Subject: [PATCH 2/2] fix checkstyle Signed-off-by: weimingdiit --- .../apache/auron/paimon/AuronPaimonV2IntegrationSuite.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/thirdparty/auron-paimon/src/test/scala/org/apache/auron/paimon/AuronPaimonV2IntegrationSuite.scala b/thirdparty/auron-paimon/src/test/scala/org/apache/auron/paimon/AuronPaimonV2IntegrationSuite.scala index 41d8fbdc9..a2539285a 100644 --- a/thirdparty/auron-paimon/src/test/scala/org/apache/auron/paimon/AuronPaimonV2IntegrationSuite.scala +++ b/thirdparty/auron-paimon/src/test/scala/org/apache/auron/paimon/AuronPaimonV2IntegrationSuite.scala @@ -406,7 +406,8 @@ class AuronPaimonV2IntegrationSuite test("paimon v2 native scan falls back for unsupported data types") { withTable("paimon.db.t_unsupported_type") { - sql("create table paimon.db.t_unsupported_type (id int, amount decimal(38, 10)) using paimon") + sql( + "create table paimon.db.t_unsupported_type (id int, amount decimal(38, 10)) using paimon") sql( "insert into paimon.db.t_unsupported_type values " + "(1, cast(123.45 as decimal(38, 10)))")