root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix duplicate condition in ReadOnlyWindowStoreStub (#17540) 

Reviewers: Ken Huang <s7133700@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Dmitry Werner 2024-10-22 23:23:14 +05:00 committed by GitHub
parent edb623cf67
commit 1c405875fa
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreStub.java
View File

@ -268,7 +268,7 @@ public class ReadOnlyWindowStoreStub<K, V> implements ReadOnlyWindowStore<K, V>,
final NavigableMap<K, V> kvMap = data.get(now);
if (kvMap != null) {
final NavigableMap<K, V> kvSubMap;
if (keyFrom == null && keyFrom == null) {
if (keyFrom == null && keyTo == null) {
kvSubMap = kvMap;
} else if (keyFrom == null) {
kvSubMap = kvMap.headMap(keyTo, true);
@ -324,7 +324,7 @@ public class ReadOnlyWindowStoreStub<K, V> implements ReadOnlyWindowStore<K, V>,
final NavigableMap<K, V> kvMap = data.get(now);
if (kvMap != null) {
final NavigableMap<K, V> kvSubMap;
if (keyFrom == null && keyFrom == null) {
if (keyFrom == null && keyTo == null) {
kvSubMap = kvMap;
} else if (keyFrom == null) {
kvSubMap = kvMap.headMap(keyTo, true);