Skip to content

Commit 6c22ad2

Browse files
committed
Handle dynamic offset index after adding columns in tiering IT
1 parent 2d73068 commit 6c22ad2

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -560,8 +560,9 @@ private void checkDataInPaimonAppendOnlyTable(
560560
InternalRow flussRow = flussRowIterator.next();
561561
assertThat(row.getInt(0)).isEqualTo(flussRow.getInt(0));
562562
assertThat(row.getString(1).toString()).isEqualTo(flussRow.getString(1).toString());
563-
// the idx 2 is __bucket, so use 3
564-
assertThat(row.getLong(3)).isEqualTo(startingOffset++);
563+
// system columns are always the last three: __bucket, __offset, __timestamp
564+
int offsetIndex = row.getFieldCount() - 2;
565+
assertThat(row.getLong(offsetIndex)).isEqualTo(startingOffset++);
565566
}
566567
assertThat(flussRowIterator.hasNext()).isFalse();
567568
}

0 commit comments

Comments
 (0)