Search results

[metrics] Add scanner. last_poll_seconds_ago consumer liveness gauge

Status: Open.

Task

#554 In apache/fluss-rust;

· charlesdong1991 opened on May 16, 2026

[metrics] Add scanner poll-timing metrics for consumer liveness observability

Status: Open.

Task

#552 In apache/fluss-rust;

· charlesdong1991 opened on May 16, 2026

[metrics] Add scanner fetch and remote download metrics for client observability

Status: Open.

Task

#551 In apache/fluss-rust;

· charlesdong1991 opened on May 16, 2026

[rust] Integration tests for map dt

Status: Open.

Task

#549 In apache/fluss-rust;

· fresh-borzoni opened on May 15, 2026

[rust] Apply schema evolution on log scan path (batch + row)

Status: Open.

Task

#547 In apache/fluss-rust;

· fresh-borzoni opened on May 15, 2026

[c++] Add to_arrow_batch_reader support in C++ binding

Status: Open.

Task

#546 In apache/fluss-rust;

· charlesdong1991 opened on May 14, 2026

[python] Add asyncio-native streaming API for bounded log reading

Status: Open.

Task

#545 In apache/fluss-rust;

· charlesdong1991 opened on May 11, 2026

[rust] Port Java's typed Arrow column-vector pattern to scan path of Row dt

Status: Open.

Task

#543 In apache/fluss-rust;

· fresh-borzoni opened on May 10, 2026

[rust] Lookuper / PrefixKeyLookuper: switch to &self lookup for pipelining

Status: Open.

Task

#541 In apache/fluss-rust;

· fresh-borzoni opened on May 10, 2026

[rust][tests] Add DynamicWriteBatchSizeEstimator integration tests

Status: Open.

Task

#539 In apache/fluss-rust;

· fresh-borzoni opened on May 9, 2026

[c++] Support prefix lookup

Status: Open.

Task

#537 In apache/fluss-rust;

· fresh-borzoni opened on May 9, 2026

Surface a typed error when ApiVersionsResponse fields exceed int16 range

Status: Open.

Task

#535 In apache/fluss-rust;

· fresh-borzoni opened on May 9, 2026