fredia commented on code in PR #25501:
URL: https://github.com/apache/flink/pull/25501#discussion_r1809809121
##########
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateContext.java:
##########
@@ -67,6 +67,12 @@ default boolean isRestored() {
*/
InternalTimeServiceManager<?> internalTimerServiceManager();
+ /**
+ * Returns the internal timer service manager create by async state
backend for the stream
+ * operator. This method returns null for non-keyed operators.
+ */
+ InternalTimeServiceManager<?> asyncInternalTimerServiceManager();
Review Comment:
> Are there cases in which an operator needs to use async timer service and
sync timer service simultaneously?
No, it is up to the developer to decide which one to use.
This is to keep it consistent with the current `asyncStateBackend` and
`KeyedStateBackend`, we will sort out the relationship between
`asyncStateBackend`/`keyedStateBackend` and `asyncTimerManager`/`timerManager`
in subsequent PR.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
