Skip to content

Commit 1e07f3f

Browse files
committed
Fix tiering add-column IT to supply new column values
1 parent 58ee7dc commit 1e07f3f

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/tiering/PaimonTieringITCase.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -635,7 +635,9 @@ void testTieringWithAddColumn() throws Exception {
635635
admin.alterTable(tablePath, addColumnChanges, false).get();
636636

637637
// 6. Write more data after ADD COLUMN (with new column value)
638-
List<InternalRow> newRows = Arrays.asList(row(4, "v4"), row(5, "v5"), row(6, "v6"));
638+
// schema now has 3 business columns (c1, c2, c3), so provide value for the new column
639+
List<InternalRow> newRows =
640+
Arrays.asList(row(4, "v4", 40), row(5, "v5", 50), row(6, "v6", 60));
639641
writeRows(tablePath, newRows, true);
640642

641643
// 7. Wait for new data to be tiered

0 commit comments

Comments
 (0)