[GitHub] [kafka] lihaosky commented on a change in pull request #11887: KAFKA-13690: Fix flaky test in EosIntegrationTest

[GitBox <gi...@apache.org>]

lihaosky commented on a change in pull request #11887:
URL: https://github.com/apache/kafka/pull/11887#discussion_r825619550



##########
File path: streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##########
@@ -1088,17 +1036,21 @@ private void writeInputData(final List<KeyValue<Long, Long>> records) {
 
     private void verifyStateStore(final KafkaStreams streams,
                                   final Set<KeyValue<Long, Long>> expectedStoreContent,
-                                  final String reason) throws Exception {
-        final ReadOnlyKeyValueStore<Long, Long> store = IntegrationTestUtils
-            .getStore(300_000L, storeName, streams, QueryableStoreTypes.keyValueStore());
-        assertNotNull(store);
-
-        try (final KeyValueIterator<Long, Long> it = store.all()) {

Review comment:
       noob question: when does `org.apache.kafka.streams.errors.InvalidStateStoreException: The state store, store, may have migrated to another instance.` happen?




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org