yunfengzhou-hub commented on code in PR #25501:
URL: https://github.com/apache/flink/pull/25501#discussion_r1809757295
##########
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? I'm wondering if we could reduce
`internalTimerServiceManager()` and `asyncInternalTimerServiceManager()` into
one method, given that they have the same return type, and it might better help
hiding implementation details from invokers.
--
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
