fhueske commented on code in PR #27962:
URL: https://github.com/apache/flink/pull/27962#discussion_r3110215249
##########
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/AbstractProcessTableOperator.java:
##########
@@ -145,11 +146,17 @@ public void open() throws Exception {
FunctionUtils.openFunction(processTableRunner,
DefaultOpenContext.INSTANCE);
}
+ @Override
+ public final boolean useInterruptibleTimers(ReadableConfig config) {
Review Comment:
I added the final on purpose to prevent this function from being overwritten
by extending classes.
AbstractProcessTableOperator is an internal class. If it becomes necessary
for a child class to overwrite the the method, we can always remove the final.
Until then, it documents that all child classes must be able to handle
interruptible timers.
--
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]
