This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new 6eef96881 [test] Fix flaky AdjustIsrITCase#testIsrShrinkAndExpand by
using acks=1 (#2468)
6eef96881 is described below
commit 6eef96881ee0ba22b5e0613f3760da8037bf8768
Author: Zübeyir Eser <[email protected]>
AuthorDate: Sun Jan 25 16:13:49 2026 +0100
[test] Fix flaky AdjustIsrITCase#testIsrShrinkAndExpand by using acks=1
(#2468)
Since `produceLog` is only used to trigger ISR shrinking and does not
require strong durability guarantees, it doesn’t need to wait for full ISR
acknowledgment. We can set its `acks` to `1`, allowing the produce request to
succeed immediately without waiting for all in-sync replicas.
This change avoids the timeout exception in the test while still
effectively triggering ISR shrinking: once a follower is stopped, it will
exceed `LOG_REPLICA_MAX_LAG_TIME`, prompting the controller to update the
`LeaderAndIsr` in ZooKeeper accordingly.
---
.../src/test/java/org/apache/fluss/server/replica/AdjustIsrITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fluss-server/src/test/java/org/apache/fluss/server/replica/AdjustIsrITCase.java
b/fluss-server/src/test/java/org/apache/fluss/server/replica/AdjustIsrITCase.java
index 933abd231..2931ca546 100644
---
a/fluss-server/src/test/java/org/apache/fluss/server/replica/AdjustIsrITCase.java
+++
b/fluss-server/src/test/java/org/apache/fluss/server/replica/AdjustIsrITCase.java
@@ -98,7 +98,7 @@ public class AdjustIsrITCase {
RpcMessageTestUtils.newProduceLogRequest(
tableId,
tb.getBucket(),
- -1,
+ 1,
genMemoryLogRecordsByObject(DATA1)))
.get(),
0,
