HOTFIX: fix the VersionedKeyValueToBytesStoreAdapter#isOpen API (#13695)

ableegoldman · ableegoldman · commit 49400b7bc346 · 2023-05-10T13:40:11.000-07:00
The VersionedKeyValueToBytesStoreAdapter#isOpen API accidentally returns the value of inner.persistent() when it should be returning inner.isOpen()

Reviewers: Matthias J. Sax &lt;mjsax@apache.org&gt;, Luke Chen &lt;showuon@gmail.com&gt;, Bruno Cadonna &lt;cadonna@apache.org&gt;, Victoria Xia &lt;victoria.xia@confluent.io&gt;
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/VersionedKeyValueToBytesStoreAdapter.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/VersionedKeyValueToBytesStoreAdapter.java
@@ -115,7 +115,7 @@ public boolean persistent() {
 
     @Override
     public boolean isOpen() {
-        return inner.persistent();
+        return inner.isOpen();
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -115,7 +115,7 @@ public boolean persistent() {`
`115`	`115`
`116`	`116`	`@Override`
`117`	`117`	`public boolean isOpen() {`
`118`		`- return inner.persistent();`
	`118`	`+ return inner.isOpen();`
`119`	`119`	`}`
`120`	`120`
`121`	`121`	`@Override`