Skip to content

Commit 2d73068

Browse files
committed
Adjust tiering add-column IT to expect actual column names
1 parent 1e07f3f commit 2d73068

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -649,8 +649,8 @@ void testTieringWithAddColumn() throws Exception {
649649
FileStoreTable paimonTable = (FileStoreTable) paimonCatalog.getTable(tableIdentifier);
650650
List<String> fieldNames = paimonTable.rowType().getFieldNames();
651651

652-
// Should have: c1, c2, c3, __bucket, __offset, __timestamp
653-
assertThat(fieldNames).contains("c1", "c2", "c3");
652+
// Should have: a, b, c3, __bucket, __offset, __timestamp
653+
assertThat(fieldNames).contains("a", "b", "c3");
654654

655655
// 9. Verify all data is present in Paimon (no data loss)
656656
List<InternalRow> allRows = new ArrayList<>();

0 commit comments

Comments
 (0)