[kafka] branch 2.6 updated: HOTFIX: fix shouldNotAccessJoinStoresWhenGivingName

[guozhang]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch 2.6
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.6 by this push:
     new 889fd31  HOTFIX: fix shouldNotAccessJoinStoresWhenGivingName
889fd31 is described below

commit 889fd31b207b86db6d059792131d14389639d9e4
Author: Guozhang Wang <wangg...@gmail.com>
AuthorDate: Thu Oct 8 14:30:12 2020 -0700

    HOTFIX: fix shouldNotAccessJoinStoresWhenGivingName
---
 .../kafka/streams/integration/StreamStreamJoinIntegrationTest.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java
index c503a98..0923668 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java
@@ -94,7 +94,7 @@ public class StreamStreamJoinIntegrationTest extends 
AbstractJoinIntegrationTest
 
             kafkaStreams.start();
             latch.await();
-            assertThrows(InvalidStateStoreException.class, () -> 
kafkaStreams.store(StoreQueryParameters.fromNameAndType("join-store", 
QueryableStoreTypes.keyValueStore())));
+            assertThrows(InvalidStateStoreException.class, () -> 
kafkaStreams.store(StoreQueryParameters.fromNameAndType("join-store", 
QueryableStoreTypes.keyValueStore())).get(1));
         }
     }