bookkeeper

bookkeeper copied to clipboard

[BUG] Entry log unknown buggy header cause data can't be read.

2

**BUG REPORT** version pulsar 2.11.2 bookkeeper the GarbageCollectorThread hang cause data can't be collected because when it extract log metadata an exception throws. ``` 2023-07-08T22:14:49,412+0800 [GarbageCollectorThread-19-1] WARN org.apache.bookkeeper.bookie.EntryLogger - error...

lifepuzzlefun

Fix negative position read on BufferedChannel cause data can't read problem.

4

Descriptions of the changes in this PR: ### Motivation fix #4022 #### in brief of this change. When do compaction. worker thread try to extract the ledgerLogger metadata header to...

lifepuzzlefun

Bookie server runtime.exit() never trigger after registerBookie failed

3

**BUG REPORT** Bookie server runtime.exit() never trigger after registerBookie failed ``` try { stateManager.registerBookie(true).get(); } catch (Exception e) { LOG.error("Couldn't register bookie with zookeeper, shutting down : ", e); shutdown(ExitCode.ZK_REG_FAIL);...

xiang092689

Run table service as a bookkeeper lifecycle component in bookie server

3

### Motivation Run table service as a bookkeeper lifecycle component in bookie server. ### Changes Add `TABLE_SERVICE_ENABLED` parameter in `EmbeddedServer` to control the startup of table service.

XuQianJin-Stars

Issue #4033: Added a flush function to run flush without commit

6

Descriptions of the changes in this PR: Added a sync method for AppendOnlyWriter ### Motivation We are testing using Distributedlog as HBase WAL storage. For HBase, there are three different...

YutSean

Fix getLedgerDirsListener

3

### Motivation The ledgerDirsListener in SingleDirectoryDbLedgerStorage is currently triggered by a ledger directory that does not belong to this storage. ### Changes To address this issue, we can introduce a...

gaozhangmin

Add diskUnderWarnThreshold check event to prevent gcThread suspended forever

5

### Motivation This code snippet implements disk check event trigger if disk usage is above warnThreshold, either marjor is suspend or forcegc is enabled. There exists a case that if...

gaozhangmin

**FEATURE REQUEST** 1. We are using the distributedlog as a WAL storage. Currently, the AppendOnlyWriter only support a force method to make sure the data is already persistently stored in...

YutSean

PerChannelBookieClient Enhancement: Self-Recovery Support in Corrupte…

1

### Motivation In the context of popular protocols like LengthBasedFrame, which typically determine total message length based on the first 0-4 bytes (for example, if the initial bytes are 00000014,...

hezhangjian

org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /test-ledgers/available/test-bookie-1 at org.apache.zookeeper.KeeperException.create(KeeperException.java:118) ~[zookeeper-3.8.0.jar:3.8.0] at org.apache.zookeeper.KeeperException.create(KeeperException.java:54) ~[zookeeper-3.8.0.jar:3.8.0] at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:1347) ~[zookeeper-3.8.0.jar:3.8.0] at org.apache.bookkeeper.zookeeper.ZooKeeperClient$9.call(ZooKeeperClient.java:716) ~[classes/:?] at org.apache.bookkeeper.zookeeper.ZooKeeperClient$9.call(ZooKeeperClient.java:708) ~[classes/:?] at org.apache.bookkeeper.zookeeper.ZooWorker.syncCallWithRetries(ZooWorker.java:140) ~[classes/:?] at org.apache.bookkeeper.zookeeper.ZooKeeperClient.create(ZooKeeperClient.java:708) ~[classes/:?] at org.apache.bookkeeper.discover.ZKRegistrationManager.doRegisterBookie(ZKRegistrationManager.java:266) ~[classes/:?]...

gvanyao