vvcephei commented on a change in pull request #11582:
URL: https://github.com/apache/kafka/pull/11582#discussion_r771459374
##########
File path:
streams/src/main/java/org/apache/kafka/streams/query/FailureReason.java
##########
@@ -52,5 +52,12 @@
* The requested store partition does not exist at all. For example,
partition 4 was requested,
* but the store in question only has 4 partitions (0 through 3).
*/
- DOES_NOT_EXIST;
+ DOES_NOT_EXIST,
+
+ /**
+ * The store that handled the query got an exception during query
execution. The message
+ * will contain the exception details. Depending on the nature of the
exception, the caller
+ * may be able to retry this instance or may need to try a different
instance.
+ */
+ STORE_EXCEPTION;
Review comment:
Thanks! @guozhangwang reminded me during the discussion to make sure
that all the cases in that KIP were accounted for. Some are still exceptions,
and some are now FailureReasons:
https://lists.apache.org/thread/brvwvpvsbsfvqpqg6jvry5hqny0vm2tr
--
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-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
