This is an automated email from the ASF dual-hosted git repository.
chia7712 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 bc797b077f1 KAFKA-19314 Remove unnecessary code of closing
snapshotWriter (#19763)
bc797b077f1 is described below
commit bc797b077f1843d93a16028b25a5f9839cfb2c85
Author: Jing-Jia Hung <[email protected]>
AuthorDate: Fri May 23 03:57:14 2025 +0800
KAFKA-19314 Remove unnecessary code of closing snapshotWriter (#19763)
- Remove redundant close of `snapshotWriter`.
- `snapshotWriter` is already closed by `RaftSnapshotWriter#writer`.
Reviewers: Jhen-Yung Hsu <[email protected]>, Ken Huang
<[email protected]>, Chia-Ping Tsai <[email protected]>
---
.../src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java | 1 -
1 file changed, 1 deletion(-)
diff --git
a/metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java
b/metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java
index 398e3fdae8a..cb025823bf4 100644
---
a/metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java
+++
b/metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java
@@ -158,7 +158,6 @@ public class SnapshotEmitter implements
SnapshotGenerator.Emitter {
throw e;
} finally {
Utils.closeQuietly(writer, "RaftSnapshotWriter");
- Utils.closeQuietly(snapshotWriter.get(), "SnapshotWriter");
}
}
}
