StephanEwen commented on pull request #14314:
URL: https://github.com/apache/flink/pull/14314#issuecomment-739252188
@becketqin I think there is some mixup with the Task's lifecycle and the
operator's life cycle.
The Operator is pretty simple:
- open()
- do the work
- close() (successful end of input)
- dispose() cleanup, called in all cases
So this "ensure reader is closed" should be in the dispose method.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
