Kezhu Wang
Kezhu Wang
ZOOKEEPER-2678 could skip snapshot in diff sync, but diff txns are logged and committed after NEWLEADER ack. ZOOKEEPER-3911 moves txn logging before NEWLEADER ack, but the txn logging is asynchronous....
Cause: * Events are delivered to recursive watcher unconditionally. * Client could receive `NodeChildrenChanged` due to child watcher on recursive watching node's descendants. Changes: Filter out `NodeChildrenChanged` events for recursive...
This test writes txns to trigger snapshot and expects some txns remain in txn log. But snapshot taking is asynchronous, thus all txns could be written to snapshot. So in...
There are several problems in this test: * It uses `ParameterizedTest` which run tests in single jvm. But `ZooKeeperServer.enableEagerACLCheck` is `static` and loaded from env variable. * It uses `assertNotSame`...
Currently, in server side, there is only one watcher mode per path. This will destroy and corrupt old watch when client watch a watching path.
This test is asserting low performance threshold for RequestPathMetricsCollector#registerRequest. It fails at rate 20% according to jira reports. I think it caused by combination of: 1. Unstable test environment. 2....
This PR tries to fix several test failures in `RequestThrottlerTest`. First, `RequestThrottlerTest#testDropStaleRequests`. Place `Thread.sleep(200)` after `submittedRequests.take()` in `RequestThrottler#run` will fail two assertions: 1. `assertEquals(2L, (long) metrics.get("prep_processor_request_queued"))` 2. `assertEquals(1L, (long) metrics.get("request_throttle_wait_count"))`...
The same watcher was resued across different clients. It is hard to know which event will last during verification, disconnected from old client or connected from new client. A brand...
The observable behavior is that client will not get expired event from watcher. The cause is twofold: 1. `updateLastSendAndHeard` is called in reconnection so the session will not timeout. 2....
This commit tries to solve port conflict for `TestingServer` if port is unspecified(aka. `port