oxia

oxia copied to clipboard

Moved common classes used only by data-server and coordinator to `oxiad/common` so that we reduce the dependencies for the client modules

merlimat

>{"level":"warn","time":"2025-11-13T07:08:30.096846532Z","component":"internal-rpc-server","error":{"error":"rpc error: code = Code(101) desc = oxia: invalid term","kind":"*status.Error","stack":null},"leaderTerm":28122,"peer":"10.60.8.84:57978","req":{"namespace":"broker", "shard":"1", "term":"27134", "options":{"enableNotifications":true}},"time":"2025-11-13T07:08:30.096890763Z","message":"New term processing of leader failed"}

mattisonchao

mattisonchao

[server][improve] Add WAL cache to optimize replication.

3

Add WAL LogEntry cache to improve replication. Bypass page-cache and eliminate deserialization overhead when tailing-read the WAL. Under ideal conditions, the `oxia_server_wal_read_latency_milliseconds_sum` can be 0. Test the WAL via wal-perf...

dao-jun

Load balancer behavior on nodes expansion

1

When switching from 3 -> 6 nodes, the load balancer is considering the new nodes one by one, leading to multiple transfers of shards. eg: here it detects the new...

merlimat

### Motivation The current shards' load balance would not work well if the user has multiple namespaces and most traffic is in one of the namespaces. We should consider doing...

mattisonchao

``` --- FAIL: TestLeaderController_AddFollower (0.01s) leader_controller_test.go:567: Error Trace: /home/runner/work/oxia/oxia/server/leader_controller_test.go:567 Error: Received unexpected error: leaked iterators: (1) attached stack trace -- stack trace: | github.com/cockroachdb/pebble.(*DB).Close | /home/runner/go/pkg/mod/github.com/cockroachdb/[email protected]/db.go:1632 | github.com/oxia-db/oxia/server/kv.(*Pebble).Close | /home/runner/work/oxia/oxia/server/kv/kv_pebble.go:362...

mattisonchao

``` goroutine 103 [running]: github.com/streamnative/oxia/server/wal/codec.(*V2).ReadIndex(0x35b83a0, {0xc00005bbc0, 0x26}) /src/oxia/server/wal/codec/v2.go:189 +0x47d github.com/streamnative/oxia/server/wal.newReadOnlySegment({0xc0002c22e0?, 0x255fdc0?}, 0xc00012aed8?) /src/oxia/server/wal/readonly_segment.go:89 +0x16c github.com/streamnative/oxia/server/wal.(*readOnlySegmentsGroup).Get(0xc0004c38c0, 0x5de588) /src/oxia/server/wal/readonly_segments_group.go:122 +0x145 github.com/streamnative/oxia/server/wal.(*readOnlySegmentsGroup).GetLastCrc(0xc0002c22e0?, 0x19?) /src/oxia/server/wal/readonly_segments_group.go:96 +0x13 github.com/streamnative/oxia/server/wal.(*wal).recoverWal(0xc000161600) /src/oxia/server/wal/wal_impl.go:562 +0x66 github.com/streamnative/oxia/server/wal.newWal({0xc0002a8d68, 0x7}, 0x7, 0xc000515140, {0x2521100,...

mattisonchao

typo in proto Int32HashRange - fields not inclusive exclusive

1

at time of writing: ``` /** * Represents a range of hash values [min, max) */ message Int32HashRange { // The minimum inclusive hash that the shard can contain fixed32...

frankhsueh