da-daken commented on code in PR #1127:
URL: https://github.com/apache/flink-agents/pull/1127#discussion_r4033874033
##########
api/src/main/java/org/apache/flink/agents/api/context/RunnerContext.java:
##########
@@ -146,11 +146,11 @@ default boolean hasResource(String name, ResourceType
type) {
<T> T durableExecute(DurableCallable<T> callable) throws Exception;
/**
- * Asynchronously executes the provided callable with durable execution
support.
+ * Creates a deferred asynchronous durable call.
*
- * <p>On JDK 21+, this method uses Continuation to yield the current
action execution, submits
- * the callable to a thread pool, and resumes when complete. On JDK <
21, this falls back to
- * synchronous execution.
+ * <p>Creating the returned handle does not execute the callable or
reserve durable state. Use
+ * {@link #await(DurableFuture)} to execute a single call, or {@link
#gather(List)} to compose
Review Comment:
Would it be better to add a description about parallelism?
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
