[feat](fluss) Support reading Apache Fluss tables through a fluss catalog - #66399

Open

morningman wants to merge 35 commits into

apache:masterfrom

morningman:fluss-connector

Commits on Aug 3, 2026

[feat](fluss) Add the fluss connector module and its remote-call seam

morningman
and
claude
committed
360ac6f
[feat](fluss) Map fluss column types onto Doris types

morningman
and
claude
committed
ef2f341
[feat](fluss) Describe a fluss table through the connector metadata SPI

morningman
and
claude
committed
f48edfb
[feat](fluss) Add the fluss e2e docker environment

morningman
and
claude
committed
da79d18
[feat](fluss) Carry a fluss scan range to BE

morningman
and
claude
committed
fbf1049
[feat](fluss) Plan the scan of a fluss log table

morningman
and
claude
committed
67d8e72
[feat](fluss) Read a fluss log range in the BE java extension

morningman
and
claude
committed
6868277
[feat](fluss) Route a fluss scan range to the BE java scanner

morningman
and
claude
committed
a242fb1
[feat](fluss) Add the end-to-end suite for fluss log tables

morningman
and
claude
committed
59e9fc7
[fix](fluss) Depend on the fluss test-jar by classifier

morningman
and
claude
committed
8f66082
[fix](fluss) Read a range whose projection selects no column

morningman
and
claude
committed
d27b62e
[feat](fluss) Plan a primary-key table read as snapshot plus change log

morningman
and
claude
committed
e6adf98
[feat](fluss) Read a primary-key range as a snapshot merged with its log

morningman
and
claude
committed
f65d795
[test](fluss) Bake a kv snapshot into the e2e fixtures and read them back

morningman
and
claude
committed
98d3d7e
[fix](be) Stop exporting the statically linked RocksDB symbols

morningman
and
claude
committed
4b9d666
[feat](fluss) Read a fluss lake table through the paimon connector

morningman
and
claude
committed
6a5d5d4
[fix](fluss) Call the lake sibling under its own classloader

morningman
and
claude
committed
a3ae2b7
[feat](fluss) Read a tiered log table as its lake plus the log after it

morningman
and
claude
committed
d9b5559
[fix](paimon) Claim the table handles this connector produces

morningman
and
claude
committed
3efa3f2
[fix](be) Pick the table reader per scan range, not per scan node

morningman
and
claude
committed
927de84
[fix](fluss) Fail loudly when the lake sibling disowns its own handle

morningman
and
claude
committed
03e73d6
[test](fluss) Read a tiered table end to end, lake only and lake plus log

morningman
and
claude
committed
b2a22df
[feat](fluss) Read a tiered primary-key table from fluss alone

morningman
and
claude
committed
82aab4f
[test](fluss) Pin what a tiered primary-key table reads as

morningman
and
claude
committed
cbbab7d
[test](fluss) Record the fluss suites' results in baseline files

morningman
and
claude
committed
e754eb5
[feat](paimon) Say which bucket a scan range came from

morningman
and
claude
committed
212f086
[test](fluss) Drive the reader from a projection BE built itself

morningman
and
claude
committed
3285a8e
[feat](connector) Let a connector name the columns its reader must read

morningman
and
claude
committed
cc317fe
[feat](fluss) Plan a primary-key lake table as its lake plus its log tail

morningman
and
claude
committed
46a6dc7
[feat](fluss) Read the log tail of a primary-key table as the state it ended in

morningman
and
claude
committed
846c50a
[feat](fluss) Read a primary-key lake split without the rows its log tail replaced

morningman
and
claude
committed
ecfec2a
[feat](be) Dispatch a wrapped lake split to the reader that unwraps it

morningman
and
claude
committed
bdf964e
[test](fluss) Read a primary-key lake table on the shapes one bucket hides

morningman
and
claude
committed
432ff2f
[feat](fluss) Refuse a partition column fluss cannot keep the value of

morningman
and
claude
committed
c052dfc
[test](fluss) Read every type, every partition type and a hundred thousand rows

morningman
and
claude
committed
64b1fb8

Navigation Menu

Uh oh!

[feat](fluss) Support reading Apache Fluss tables through a fluss catalog - #66399

[feat](fluss) Support reading Apache Fluss tables through a fluss catalog#66399
morningman wants to merge 35 commits into
apache:masterfrom
morningman:fluss-connector

Commits on Aug 3, 2026

[feat](fluss) Add the fluss connector module and its remote-call seam

[feat](fluss) Map fluss column types onto Doris types

[feat](fluss) Describe a fluss table through the connector metadata SPI

[feat](fluss) Add the fluss e2e docker environment

[feat](fluss) Carry a fluss scan range to BE

[feat](fluss) Plan the scan of a fluss log table

[feat](fluss) Read a fluss log range in the BE java extension

[feat](fluss) Route a fluss scan range to the BE java scanner

[feat](fluss) Add the end-to-end suite for fluss log tables

[fix](fluss) Depend on the fluss test-jar by classifier

[fix](fluss) Read a range whose projection selects no column

[feat](fluss) Plan a primary-key table read as snapshot plus change log

[feat](fluss) Read a primary-key range as a snapshot merged with its log

[test](fluss) Bake a kv snapshot into the e2e fixtures and read them back

[fix](be) Stop exporting the statically linked RocksDB symbols

[feat](fluss) Read a fluss lake table through the paimon connector

[fix](fluss) Call the lake sibling under its own classloader

[feat](fluss) Read a tiered log table as its lake plus the log after it

[fix](paimon) Claim the table handles this connector produces

[fix](be) Pick the table reader per scan range, not per scan node

[fix](fluss) Fail loudly when the lake sibling disowns its own handle

[test](fluss) Read a tiered table end to end, lake only and lake plus log

[feat](fluss) Read a tiered primary-key table from fluss alone

[test](fluss) Pin what a tiered primary-key table reads as

[test](fluss) Record the fluss suites' results in baseline files

[feat](paimon) Say which bucket a scan range came from

[test](fluss) Drive the reader from a projection BE built itself

[feat](connector) Let a connector name the columns its reader must read

[feat](fluss) Plan a primary-key lake table as its lake plus its log tail

[feat](fluss) Read the log tail of a primary-key table as the state it ended in

[feat](fluss) Read a primary-key lake split without the rows its log tail replaced

[feat](be) Dispatch a wrapped lake split to the reader that unwraps it

[test](fluss) Read a primary-key lake table on the shapes one bucket hides

[feat](fluss) Refuse a partition column fluss cannot keep the value of

[test](fluss) Read every type, every partition type and a hundred thousand rows