davidradl commented on code in PR #26395:
URL: https://github.com/apache/flink/pull/26395#discussion_r2027194352
##########
flink-runtime/src/main/java/org/apache/flink/streaming/api/transformations/OneInputTransformation.java:
##########
@@ -195,6 +196,11 @@ public boolean isInternalSorterSupported() {
@Override
public void enableAsyncState() {
- // nothing to do.
+ OneInputStreamOperator<IN, OUT> operator =
+ (OneInputStreamOperator<IN, OUT>)
+ ((SimpleOperatorFactory<OUT>)
operatorFactory).getOperator();
+ if (!(operator instanceof AsyncStateProcessingOperator)) {
+ super.enableAsyncState();
Review Comment:
I am curious shouldn't this be an error?
As is the caller amkes this call anf would assume that async is enabled, but
it is not.
--
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]
