Skip to content

Commit cd66a59

Browse files
buvbwuchong
authored andcommitted
Handle dynamic offset index after adding columns in tiering IT
1 parent d07785a commit cd66a59

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
@@ -559,8 +559,9 @@ private void checkDataInPaimonAppendOnlyTable(
559559
InternalRow flussRow = flussRowIterator.next();
560560
assertThat(row.getInt(0)).isEqualTo(flussRow.getInt(0));
561561
assertThat(row.getString(1).toString()).isEqualTo(flussRow.getString(1).toString());
562-
// the idx 2 is __bucket, so use 3
563-
assertThat(row.getLong(3)).isEqualTo(startingOffset++);
562+
// system columns are always the last three: __bucket, __offset, __timestamp
563+
int offsetIndex = row.getFieldCount() - 2;
564+
assertThat(row.getLong(offsetIndex)).isEqualTo(startingOffset++);
564565
}
565566
assertThat(flussRowIterator.hasNext()).isFalse();
566567
}

0 commit comments

Comments
 (0)