Skip to content

Commit 5946c5b

Browse files
committed
fix tests
1 parent c831cf4 commit 5946c5b

File tree

1 file changed

+13
-2
lines changed

1 file changed

+13
-2
lines changed

fluss-lake/fluss-lake-paimon/src/test/java/com/alibaba/fluss/lake/paimon/tiering/FlussRecordAsPaimonRowTest.java

Lines changed: 13 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,12 @@ void testLogTableRecordAllTypes() {
6060
new org.apache.paimon.types.LocalZonedTimestampType(6),
6161
new org.apache.paimon.types.TimestampType(6),
6262
new org.apache.paimon.types.BinaryType(),
63-
new org.apache.paimon.types.VarCharType());
63+
new org.apache.paimon.types.VarCharType(),
64+
// append three system columns: __bucket, __offset,__timestamp
65+
new org.apache.paimon.types.IntType(),
66+
new org.apache.paimon.types.BigIntType(),
67+
new org.apache.paimon.types.LocalZonedTimestampType(3));
68+
6469
FlussRecordAsPaimonRow flussRecordAsPaimonRow =
6570
new FlussRecordAsPaimonRow(tableBucket, tableRowType);
6671
long logOffset = 0;
@@ -122,7 +127,13 @@ void testLogTableRecordAllTypes() {
122127
@Test
123128
void testPrimaryKeyTableRecord() {
124129
int tableBucket = 0;
125-
RowType tableRowType = RowType.of(new org.apache.paimon.types.BooleanType());
130+
RowType tableRowType =
131+
RowType.of(
132+
new org.apache.paimon.types.BooleanType(),
133+
// append three system columns: __bucket, __offset,__timestamp
134+
new org.apache.paimon.types.IntType(),
135+
new org.apache.paimon.types.BigIntType(),
136+
new org.apache.paimon.types.LocalZonedTimestampType(3));
126137
FlussRecordAsPaimonRow flussRecordAsPaimonRow =
127138
new FlussRecordAsPaimonRow(tableBucket, tableRowType);
128139
long logOffset = 0;

0 commit comments

Comments
 (0)