Cong Zhao

[improve][client-c++]Support include message header size when check maxMessageSize

3

Master Issue: #17188 ### Motivation See: #17188 ### Modifications Support include message header size when check maxMessageSize for cpp client ### Verifying this change - [x] Make sure that the...

[fix][client] Support LocalDateTime Conversion

1

Fixes #18329 ### Motivation Due to missing LocalDateTime ConVersion, the decode `java.time.LocalDateTime` failure. ### Modifications Add `LocalTimestampMicrosConversion` and `LocalTimestampMillisConversion` for AvroSchema. ### Verifying this change - [x] Make sure that...

[fix][broker] fix consume stuck of shared streaming dispatcher

1

Fixes #18314 ### Motivation In #18289, we set `sendInProgress` to false only after the last entry in a batch of messages has been delivered, but this will make consume stuck,...

Flaky-test: PersistentTopicStreamingDispatcherE2ETest.testMessageRedelivery

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/actions/runs/3377038718/jobs/5605505912#step:8:1667 ### Exception stacktrace Full exception stacktrace Error: testMessageRedelivery(org.apache.pulsar.broker.service.persistent.PersistentTopicStreamingDispatcherE2ETest) Time elapsed: 1.14...

[fix][broker][branch-2.8] Fix watcher count on ZK increasing indefinitely

5

### Motivation I find some z-node only call `exist` and add watcher, but `ExistsWatchRegistration` still will be registered even though the z-node may never be created. this will lead to...

[fix][broker][branch-3.1] Avoid PublishRateLimiter use an already closed RateLimiter

8

### Motivation We found the following error logs on the broker when we used ResourceGroupPublishLimiter. This root cause is `tryAcquire` method has a race condition with the `replaceLimiters` method, leading...

### Motivation Currently, if only broker-level EntryFilters are used, each topic will repeatedly load EntryFilters, which is unnecessary. ### Modifications If only broker-level EntryFilters are set, then we don't load...

### Feature Description (功能描述) Support rest-api for manage computer jobs by [computer-k8s](https://github.com/apache/incubator-hugegraph-computer/tree/master/computer-k8s) Driver: https://github.com/apache/incubator-hugegraph-computer/blob/master/computer-k8s/src/main/java/org/apache/hugegraph/computer/k8s/driver/KubernetesDriver.java

Flaky-test: ShadowManagedLedgerImplTest.testShadowWrites

4

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/actions/runs/8415552736/job/23056991961?pr=22335 ### Exception stacktrace ``` Error: org.apache.bookkeeper.mledger.impl.ShadowManagedLedgerImplTest.testShadowWrites Time elapsed: 10.183 s

[Bug] The origin future must be null

4

### Bug Type (问题类型) exception / error (运行异常) ### Before submit - [X] 我已经确认现有的 [Server-Issues](https://github.com/hugegraph/hugegraph/issues) 与 [Computer-Issues](https://github.com/hugegraph/hugegraph-computer/issues) 中没有相同 / 重复问题 ### Environment (环境信息) CI ### Expected & Actual behavior (期望与实际表现)...