This is an automated email from the ASF dual-hosted git repository.
JingsongLi 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 e7ef0cbfad [spark] Fix legacy binary partition test expectations
(#10676)
e7ef0cbfad is described below
commit e7ef0cbfad28f9e6d3ca40d49386fce46ca82305
Author: Jingsong Lee <[email protected]>
AuthorDate: Tue Oct 20 12:23:33 2026 +0800
[spark] Fix legacy binary partition test expectations (#10676)
---
.../scala/org/apache/paimon/spark/sql/DDLTestBase.scala | 17 +++++------------
1 file changed, 5 insertions(+), 12 deletions(-)
diff --git
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala
index a81d9dad9f..a5222fc8a7 100644
---
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala
+++
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala
@@ -1109,18 +1109,11 @@ abstract class DDLTestBase extends PaimonSparkTestBase {
|tblproperties('partition.legacy-name'='$legacyPartName');
|""".stripMargin)
- if (legacyPartName) {
- spark.sql("insert into table p_t values(1, 'a', cast('2021' as
binary))")
- intercept[Exception] {
- spark.sql("SELECT * FROM p_t").collect()
- }
- } else {
- spark.sql("insert into table p_t values(1, 'a', cast('2021' as
binary))")
- checkAnswer(spark.sql("SELECT * FROM p_t"), Row(1, "a",
"2021".getBytes))
- val path = spark.sql("SELECT __paimon_file_path FROM
p_t").collect()
- assert(path.length == 1)
- assert(path.head.getString(0).contains("/day=2021/"))
- }
+ spark.sql("insert into table p_t values(1, 'a', cast('2021' as
binary))")
+ checkAnswer(spark.sql("SELECT * FROM p_t"), Row(1, "a",
"2021".getBytes))
+ val path = spark.sql("SELECT __paimon_file_path FROM p_t").collect()
+ assert(path.length == 1)
+ assert(path.head.getString(0).contains("/day=2021/"))
}
withTable("p_t") {
