Skip to content

Commit 2243d64

Browse files
committed
fix
1 parent 83e6519 commit 2243d64

File tree

1 file changed

+16
-2
lines changed

1 file changed

+16
-2
lines changed

paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/RowTrackingTestBase.scala

Lines changed: 16 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,9 @@ abstract class RowTrackingTestBase extends PaimonSparkTestBase {
175175
|WHEN MATCHED THEN
176176
|UPDATE SET t.id = s.id, t.b = s.b + t.b, t.c = s.c + t.c
177177
|""".stripMargin).collect())
178-
sql(s"INSERT INTO t VALUES ($i, $i, $i)")
178+
if (i > 1) {
179+
sql(s"INSERT INTO t VALUES ($i, $i, $i)")
180+
}
179181
}
180182
}
181183

@@ -198,7 +200,19 @@ abstract class RowTrackingTestBase extends PaimonSparkTestBase {
198200
Await.result(mergeInto, 60.seconds)
199201
Await.result(compact, 60.seconds)
200202

201-
checkAnswer(sql("SELECT * FROM t"), Seq(Row(1, 10, 10)))
203+
checkAnswer(
204+
sql("SELECT * FROM t"),
205+
Seq(
206+
Row(1, 10, 10),
207+
Row(2, 2, 2),
208+
Row(3, 3, 3),
209+
Row(4, 4, 4),
210+
Row(5, 5, 5),
211+
Row(6, 6, 6),
212+
Row(7, 7, 7),
213+
Row(8, 8, 8),
214+
Row(9, 9, 9),
215+
Row(10, 10, 10)))
202216
}
203217
}
204218

0 commit comments

Comments
 (0)