This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 62ba4d3d4e MINOR: Remove extraneous code in LocalLogManager (#12168)
62ba4d3d4e is described below
commit 62ba4d3d4e42cf65174472f81caf3a18d8d7ed13
Author: David Arthur <[email protected]>
AuthorDate: Wed May 18 10:58:08 2022 -0400
MINOR: Remove extraneous code in LocalLogManager (#12168)
Reviewers: Kvicii <[email protected]>, dengziming
<[email protected]>, Divij Vaidya <[email protected]>
---
metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java | 5 -----
1 file changed, 5 deletions(-)
diff --git
a/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java
b/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java
index 3c495adff9..36fe3ec2c1 100644
--- a/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java
+++ b/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java
@@ -243,11 +243,6 @@ public final class LocalLogManager implements
RaftClient<ApiMessageAndVersion>,
}
public synchronized long append(LocalBatch batch) {
- try {
- throw new RuntimeException("foo");
- } catch (Exception e) {
- log.info("WATERMELON: appending {}", batch, e);
- }
prevOffset += batch.size();
log.debug("append(batch={}, prevOffset={})", batch, prevOffset);
batches.put(prevOffset, batch);