Skip to content

Commit 5ae2728

Browse files
authored
fix(failover): fix failover get wrong node config (#2760)
Signed-off-by: Robin Han <[email protected]>
1 parent f8781a9 commit 5ae2728

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

core/src/main/scala/kafka/log/stream/s3/DefaultS3Client.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@
7272
import org.slf4j.Logger;
7373
import org.slf4j.LoggerFactory;
7474

75+
import java.util.Collections;
7576
import java.util.HashMap;
7677
import java.util.concurrent.CompletableFuture;
7778
import java.util.concurrent.TimeUnit;
@@ -272,7 +273,8 @@ public WriteAheadLog getWal(FailoverRequest request) {
272273
long nodeEpoch = request.getNodeEpoch();
273274
WalHandle walHandle = new DefaultWalHandle(clusterId);
274275
WalFactory factory = new DefaultWalFactory(nodeId, config.objectTagging(), networkInboundLimiter, networkOutboundLimiter);
275-
return new BootstrapWalV1(nodeId, nodeEpoch, request.getKraftWalConfigs(), true, factory, getNodeManager(), walHandle);
276+
NodeManager nodeManager = new NodeManagerStub(requestSender, nodeId, nodeEpoch, Collections.emptyMap());
277+
return new BootstrapWalV1(nodeId, nodeEpoch, request.getKraftWalConfigs(), true, factory, nodeManager, walHandle);
276278
}
277279
}, (wal, sm, om, logger) -> {
278280
try {

0 commit comments

Comments
 (0)