This is an automated email from the ASF dual-hosted git repository.
slfan1989 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/auron.git
The following commit(s) were added to refs/heads/master by this push:
new 0e6388dc6 [AURON #2449] Add fallback coverage for unsupported Paimon
scan data type (#2450)
0e6388dc6 is described below
commit 0e6388dc6f4c9718ded4e1383fa3dff7ef4fb196
Author: Ming Wei <[email protected]>
AuthorDate: Sun Aug 9 08:41:42 2026 +0800
[AURON #2449] Add fallback coverage for unsupported Paimon scan data type
(#2450)
**Which issue does this PR close?**
Closes #2449
**Rationale for this change**
Paimon native scan currently falls back when the read schema contains
unsupported
data types, but this behavior was not covered by the integration tests.
Adding this regression test ensures unsupported decimal types continue
to use the
Spark fallback path and do not enter native Paimon execution
accidentally.
**What changes are included in this PR?**
Adds a Paimon integration test for an unsupported `decimal(38,10)`
column.
The test:
- Writes a row using the unsupported decimal type.
- Verifies that Spark returns the expected result.
- Verifies that the executed plan does not contain
`NativePaimonV2TableScan`.
No execution logic or user-facing behavior is changed.
**Are there any user-facing changes?**
No user-facing changes.
**How was this patch tested?**
UT.
---------
Signed-off-by: weimingdiit <[email protected]>
Co-authored-by: Shilun Fan <[email protected]>
---
.../auron/paimon/AuronPaimonV2IntegrationSuite.scala | 15 +++++++++++++++
1 file changed, 15 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..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
@@ -404,6 +404,21 @@ 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(
