派生自
oss-mirrors / ICV / kafka
3540 提交 落后, 9573 提交 领先 上游代码库。
kpatelatwork
编辑于
KAFKA-13785: [10/N][emit final] more unit test for session store and disable cache for emit final sliding window (#12370) (#7137)
1. Added more unit test for RocksDBTimeOrderedSessionStore and RocksDBTimeOrderedSessionSegmentedBytesStore
2. Disable cache for sliding window if emit strategy is ON_WINDOW_CLOSE
Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com>
Co-authored-by: Hao Li <1127478+lihaosky@users.noreply.github.com>
名称 | 最后提交 | 最后更新 |
---|