gaoyunhaii commented on a change in pull request #16351:
URL: https://github.com/apache/flink/pull/16351#discussion_r663625421
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
##########
@@ -853,24 +852,25 @@ private Exception runAndSuppressThrowable(
}
/**
- * Execute @link StreamOperator#dispose()} of each operator in the chain
of this {@link
- * StreamTask}. Disposing happens from <b>tail to head</b> operator in the
chain.
+ * Execute {@link StreamOperator#close()} of each operator in the chain of
this {@link
Review comment:
There is also an outdated comment in line 504
--
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
