leaves12138 commented on code in PR #6091:
URL: https://github.com/apache/paimon/pull/6091#discussion_r2287189178
##########
paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/RowLineageTestBase.scala:
##########
@@ -198,6 +198,68 @@ abstract class RowLineageTestBase extends
PaimonSparkTestBase {
}
}
+ test("Row Lineage: merge into table with with data-evolution") {
Review Comment:
Fixec
##########
paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/RowLineageTestBase.scala:
##########
@@ -198,6 +198,68 @@ abstract class RowLineageTestBase extends
PaimonSparkTestBase {
}
}
+ test("Row Lineage: merge into table with with data-evolution") {
+ if (gteqSpark3_5) {
+ withTable("s", "t") {
+ sql("CREATE TABLE s (id INT, b INT) TBLPROPERTIES
('row-tracking.enabled' = 'true')")
+ sql("INSERT INTO s VALUES (1, 11), (2, 22)")
+
+ sql(
+ "CREATE TABLE t (id INT, b INT, c INT) TBLPROPERTIES
('row-tracking.enabled' = 'true', 'data-evolution.enabled' = 'true')")
+ sql("INSERT INTO t SELECT /*+ REPARTITION(1) */ id, id AS b, id AS c
FROM range(2, 4)")
+
+ sql("""
+ |MERGE INTO t
+ |USING s
+ |ON t.id = s.id
+ |WHEN MATCHED THEN UPDATE SET t.b = s.b
+ |WHEN NOT MATCHED THEN INSERT (id, b, c) VALUES (id, b, 11)
+ |""".stripMargin)
+ checkAnswer(
+ sql("SELECT *, _ROW_ID, _SEQUENCE_NUMBER FROM t ORDER BY id"),
+ Seq(Row(1, 11, 11, 2, 2), Row(2, 22, 2, 0, 2), Row(3, 3, 3, 1, 2))
+ )
+ }
+ }
+ }
+
+ test("Row Lineage: merge into table with with data-evolution complex") {
Review Comment:
OK
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@paimon.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
