masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1590608598
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java:
##########
@@ -242,6 +248,25 @@ private KeyedStateStore
checkPreconditionsAndGetKeyedStateStore(
return keyedStateStore;
}
+ // TODO: Reconstruct this after StateManager is ready in FLIP-410.
Review Comment:
I have renamed it.
For stateDescriptorV2 and stateDescriptorV1, I think we could only support
async access for stateDescriptorV2.
It's also doable in the future to support sync access for stateDescriptorV2
which should be our inner logic.
As for supporting async access for stateDescriptorV1, it should be a bigger
topic and may need a FLIP. We could just resolve this firstly.
--
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
