You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@fluss.apache.org by GitBox <gi...@apache.org> on 2026/07/04 05:38:45 UTC
[GH] (fluss/feat/iceberg-tiering-complex-types): Workflow run "Check License" is working again!
The GitHub Actions job "Check License" on fluss.git/feat/iceberg-tiering-complex-types has succeeded.
Run started by GitHub user XuQianJin-Stars (triggered by XuQianJin-Stars).
Head commit for run:
82e499c0aa275455a00127801ae75f8e8eb513de / forwardxu <fo...@apache.org>
[lake/iceberg] Add unit tests for FlussRecordAsIcebergRecord tiering wrapper
Introduce FlussRecordAsIcebergRecordTest that mirrors the coverage matrix of FlussRecordAsPaimonRowTest, focusing on behaviors specific to the tiering wrapper on top of FlussRowAsIcebergRecord:
- All-types log-table row: dispatch of __bucket / __offset / __timestamp system columns via both positional get(pos) and name-based getField(name), alongside the existing 14 primitive/business columns delegated to the parent wrapper.
- Primary-key table with all ChangeType values (INSERT / UPDATE_BEFORE / UPDATE_AFTER / DELETE / APPEND_ONLY): asserts that offset/timestamp are refreshed on every setFlussRecord call and system columns remain consistent.
- Field count mismatch: setFlussRecord throws IllegalStateException when fluss row field count does not match struct.size - system.
- Complex-type propagation via the parent converter: ARRAY<INT>, ARRAY<ARRAY<INT>>, ARRAY with nullable / empty / null variants, MAP<STRING,INT> populated / empty / null, and ROW<INT,STRING> including a null nested row.
This mirrors the guardrails present in fluss-lake-paimon's FlussRecordAsPaimonRowTest so log-table tiering into Iceberg has equivalent unit-test coverage.
Report URL: https://github.com/apache/fluss/actions/runs/28696204500
With regards,
GitHub Actions via GitBox