KAFKA-10221: Backport fix for KAFKA-9603 to 2.5 (#8987)
KAFKA-9603 reports that the number of open files keeps increasing in RocksDB. The reason is that bulk loading is turned on but never turned off in segmented state stores for standby tasks. This bug was fixed in 2.6 through PR #8661 by using code that is not present in 2.5. So cherry-picking was not possible. Reviewers: John Roesler <vvcephei@apache.org>
显示
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyContextImpl.java 1 个添加, 1 个删除...kafka/streams/processor/internals/StandbyContextImpl.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java 6 个添加, 1 个删除...s/state/internals/AbstractRocksDBSegmentedBytesStore.java
- streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStoreTest.java 46 个添加, 6 个删除...ate/internals/AbstractRocksDBSegmentedBytesStoreTest.java
加载中
想要评论请 注册 或 登录